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 supported306 Subscribers
Add a CodeTriage badge to kafka
Help out
- Issues
- KAFKA-20684 [6/N]: Migrate core integration tests to RebalanceListener
- KAFKA-20684 [8/N]: Migrate clients tests to RebalanceListener
- KAFKA-20684 [7/N]: Point clients internals at RebalanceListener
- Fail fast in MirrorMaker 2 when source offsets become invalid
- KAFKA-20897: Add broker pods and canary partition placement isolation (KIP-1095)
- KAFKA-20889: reject empty group.instance.id values in Kafka Streams.
- KAFKA-20896: avoid epoch bump when a new config adding to a assignor
- KAFKA-12443: Add TranslateSurrogates SMT to Kafka Connect
- KAFKA-20853: Support file-based Maven publishing
- KAFKA-19996: Avoid premature ISR expansion under min ISR
- Docs
- Java not yet supported