Skip to content
Navigation Menu
Toggle navigation
Sign in
Appearance settings
Platform
GitHub Copilot
Write better code with AI
GitHub Spark
New
Build and deploy intelligent apps
GitHub Models
New
Manage and compare prompts
GitHub Advanced Security
Find and fix vulnerabilities
Actions
Automate any workflow
Codespaces
Instant dev environments
Issues
Plan and track work
Code Review
Manage code changes
Discussions
Collaborate outside of code
Code Search
Find more, search less
Explore
Why GitHub
Documentation
GitHub Skills
Blog
Integrations
GitHub Marketplace
MCP Registry
View all features
Solutions
By company size
Enterprises
Small and medium teams
Startups
Nonprofits
By use case
App Modernization
DevSecOps
DevOps
CI/CD
View all use cases
By industry
Healthcare
Financial services
Manufacturing
Government
View all industries
View all solutions
Resources
Topics
AI
DevOps
Security
Software Development
View all
Explore
Learning Pathways
Events & Webinars
Ebooks & Whitepapers
Customer Stories
Partners
Executive Insights
Open Source
GitHub Sponsors
Fund open source developers
The ReadME Project
GitHub community articles
Repositories
Topics
Trending
Collections
Enterprise
Enterprise platform
AI-powered developer platform
Available add-ons
GitHub Advanced Security
Enterprise-grade security features
Copilot for business
Enterprise-grade AI features
Premium Support
Enterprise-grade 24/7 support
Pricing
Search or jump to...
Search code, repositories, users, issues, pull requests...
Search syntax tips
Provide feedback
Saved searches
Use saved searches to filter your results more quickly
Sign in
Sign up
Appearance settings
Resetting focus
You signed in with another tab or window.
Reload
to refresh your session.
You signed out in another tab or window.
Reload
to refresh your session.
You switched accounts on another tab or window.
Reload
to refresh your session.
Dismiss alert
{{ message }}
ThreeDotsLabs
/
watermill-kafka
Public
Notifications
You must be signed in to change notification settings
Fork
40
Star
74
Code
Pull requests
2
Actions
Security
Uh oh!
There was an error while loading.
Please reload this page
.
Insights
Additional navigation options
Code
Pull requests
Actions
Security
Insights
Commits
Branch selector
master
User selector
All users
Datepicker
All time
Commit History
Commits on Sep 12, 2025
Wait for topic (#40)
Show description for bd67097
m110
authored
bd67097
Copy full SHA for bd67097
Commits on Sep 4, 2025
Default to DefaultMarshaler when not passed (#39)
m110
authored
001c4a4
Copy full SHA for 001c4a4
Commits on Aug 19, 2025
use saram defaults (version = sarama.DefaultVersion) (#38)
jgersdorf
authored
c4e3ddd
Copy full SHA for c4e3ddd
Commits on Jan 13, 2025
adjust STRESS_TEST_COUNT
roblaszczak
authored
f1be478
Copy full SHA for f1be478
Update .github/pull_request_template.md (by Terraform)
m110
committed
f0d849b
Copy full SHA for f0d849b
Update .github/pull_request_template.md (by Terraform)
m110
committed
4b36daa
Copy full SHA for 4b36daa
adjust STRESS_TEST_COUNT
roblaszczak
authored
e29b98b
Copy full SHA for e29b98b
commit offset explicitly when AutoCommit is disabled and added Test Code for Manual Commit (#25)
Show description for 008c08b
4 people
authored
008c08b
Copy full SHA for 008c08b
added new docker-compose (#37)
Show description for d852df8
roblaszczak
authored
d852df8
Copy full SHA for d852df8
Commits on Nov 22, 2024
Run CI on PR
m110
committed
e81d941
Copy full SHA for e81d941
Commits on Oct 28, 2024
Update README.md (by Terraform)
m110
committed
743324f
Copy full SHA for 743324f
Commits on Aug 30, 2024
Update README.md (by Terraform)
m110
committed
cc8111d
Copy full SHA for cc8111d
Commits on Aug 28, 2024
Add an assert
m110
committed
42b2e56
Copy full SHA for 42b2e56
Merge pull request #17 from sevaorlov/fix-ctx-after-retry
Show description for 07c306d
m110
authored
07c306d
Copy full SHA for 07c306d
Merge pull request #35 from ThreeDotsLabs/bump-deps
Show description for 07a4f15
m110
authored
07a4f15
Copy full SHA for 07a4f15
tidy
m110
committed
70923db
Copy full SHA for 70923db
Bump deps
m110
committed
41e7de1
Copy full SHA for 41e7de1
Merge pull request #22 from dferstay/fix-subscriber-close-race
Show description for 42e837c
m110
authored
42e837c
Copy full SHA for 42e837c
Commits on Aug 23, 2024
Merge pull request #33 from ThreeDotsLabs/dependabot/go_modules/golang.org/x/net-0.23.0
Show description for 1113f4e
m110
authored
1113f4e
Copy full SHA for 1113f4e
Bump golang.org/x/net from 0.17.0 to 0.23.0
Show description for 702034c
dependabot[bot]
authored
702034c
Copy full SHA for 702034c
Merge pull request #34 from ThreeDotsLabs/dependabot/go_modules/golang.org/x/crypto-0.17.0
Show description for e55420f
m110
authored
e55420f
Copy full SHA for e55420f
Update Makefile
m110
committed
8c3dc3b
Copy full SHA for 8c3dc3b
Bump golang.org/x/crypto from 0.14.0 to 0.17.0
Show description for c187fa8
dependabot[bot]
authored
c187fa8
Copy full SHA for c187fa8
Commits on Jun 27, 2024
Merge pull request #31 from wolfapple/fix/rebalancing
Show description for bfef80e
m110
authored
bfef80e
Copy full SHA for bfef80e
Merge pull request #30 from prOOrc/fix/rebalancing
Show description for 2664bae
m110
authored
2664bae
Copy full SHA for 2664bae
Commits on May 21, 2024
fix/rebalancing add session context error info
prOOrc
committed
4138e3a
Copy full SHA for 4138e3a
fix/rebalancing check session is not nil
prOOrc
committed
8ba4e35
Copy full SHA for 8ba4e35
Commits on Dec 17, 2023
Merge pull request #32 from minghsu0107/master
m110
authored
ba31b43
Copy full SHA for ba31b43
Commits on Dec 15, 2023
bump to v3
minghsu0107
committed
0ebb4d3
Copy full SHA for 0ebb4d3
add codecov make rule
minghsu0107
committed
bb42213
Copy full SHA for bb42213
Update README.md
minghsu0107
authored
4c0f133
Copy full SHA for 4c0f133
migrate to IBM/sarama
minghsu0107
committed
69fb9c4
Copy full SHA for 69fb9c4
Commits on Nov 3, 2023
Patch sarama_kafka rebalance fix
wolfapple
committed
05d796c
Copy full SHA for 05d796c
Commits on Oct 12, 2023
Merge pull request #23 from Provet/message_key
Show description for 3faf2c2
roblaszczak
authored
3faf2c2
Copy full SHA for 3faf2c2
Commits on Oct 5, 2023
fix/rebalancing
prOOrc
committed
ab57ba0
Copy full SHA for ab57ba0
Pagination
Previous
Next
You can’t perform that action at this time.