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
- MINOR: Fix raw type warnings in AbstractHeartbeatRequestManagerTest
- KAFKA-20116: Forwad task-(end)-offset to task assignor (4/N)
- KAFKA-20686: Add base integ tests for share group DLQ. [1/N]
- KAFKA-20724: prevent duplicate task in tasks() during pause and resume
- MINOR: reduce allocations constructing RecordHeaders
- KAFKA-20727: Update system tests for transactional state stores
- KAFKA-20490: Replace txn buffer skip-list with TreeMap
- MINOR: Move DelayedProduceTest to server module
- KAFKA-20116: Send task-(end)-offset only if changed (5/N)
- KAFKA-20625: Add StreamsGroupTopologyDescriptionRequestManager and Streams client topology push [2/N]
- Docs
- Java not yet supported