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
View all SubscribersAdd a CodeTriage badge to kafka
Help out
- Issues
- KAFKA-19325 improve forceComplete() in DelayedOperation
- KAFKA-14895: [1/N] Move AddPartitionsToTxnManager files to java
- KAFKA-19221: Propagate IOException on LogSegment#close
- KAFKA-15283:[1/N] Client support for OffsetCommit with topic ID
- KAFKA-19244: Add support for kafka-streams-groups.sh options (reset-offsets) [1/N]
- KAFKA-19239 Rewrite IntegrationTestUtils by java
- KAFKA-19255: KRaft request manager should support one in-flight request per request type
- KAFKA-19315: Move ControllerMutationQuotaManager to server module
- KAFKA-19144 Move DelayedProduce to server module
- KAFKA-19282: Update quotaTypesEnabled on quota removal in ClientQuotaManager
- Docs
- Java not yet supported