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 supported303 Subscribers
Add a CodeTriage badge to kafka
Help out
- Issues
- KAFKA-13810 Document behavior of KafkaProducer.flush() w.r.t callbacks
- KAFKA-13818: Add generation to consumer assignor logs
- KIP-829: (console consumer) add print.topic property
- KAFKA-13768: Don't mark expired batches as unresolved when using transactional producer
- KAFKA-12908: Load raft snapshot heuristic (WIP)
- [DO NOT MERGE] POC: type-safe processValues
- MINOR: Improve the readability of the DelegationTokenManager code
- MINOR: Unify the log output of JaasContext.defaultContext
- KAFKA-13463: Make pause behavior consistent between cooperative and eager protocols
- KAFKA-13667: Make listeners mandatory in kraft mode
- Docs
- Java not yet supported