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 supported300 Subscribers
Add a CodeTriage badge to kafka
Help out
- Issues
- KAFKA-18084: Added write locks in SharePartition where locks were async calls were being made
- KAFKA-17750: Extend kafka-consumer-groups command line tool to support new consumer group (part 1)
- Kafka-16505: Adding dead letter queue in Kafka Streams
- KIP 1090 - Reporting integration with Develocity API
- KAFKA-18067: Kafka Streams can leak Producer client under EOS
- KAFKA-18061 AddRaftVoter responds with error message "NONE" instead of null
- KAFKA-18060: new coordinator does not handle TxnOffsetCommitRequest with empty member id when using CONSUMER group
- KAFKA-18046: cache calls to LoggerFactory.getLogger() inside LogContext
- MINOR: improve Kafka Streams metrics documentation
- KAFKA-18064: SASL mechanisms that do support neihter integrity nor co…
- Docs
- Java not yet supported