kafka
https://github.com/apache/kafka
Java
Mirror of Apache Kafka
Triage Issues!
When you volunteer to triage issues, you'll receive an email each day with a link to an open issue that needs help in this project. You'll also receive instructions on how to triage issues.
Triage Docs!
Receive a documented method or class from your favorite GitHub repos in your inbox every day. If you're really pro, receive undocumented methods or classes and supercharge your commit history.
Java not yet supported307 Subscribers
Add a CodeTriage badge to kafka
Help out
- Issues
- MINOR: Update JDK fetch logic for version 25 and improve path handling
- MINOR: Fixed typos in comments across multiple Java classes
- MINOR: Update bootstrap-controller port in kraft.md example
- KAFKA-19804: Improve heartbeat request manager initial HB interval
- [WIP] Draft proposal for adding retries to timed out KS EOS commit requests
- MINOR: Use a separate map to store acknowledgements in ShareAcknowledgementEvent.
- KAFKA-19881: change CVE scanner workflow to run on active branches (wip)
- MINOR: Backport fix for test_fencing_static_consumer system test to 3.9
- KAFKA-19688: add new KStreams.process() overlaod
- KAFKA-20015: Stop sending timed out fetch requests from ShareConsumeRequestManager.
- Docs
- Java not yet supported