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 supported302 Subscribers
Add a CodeTriage badge to kafka
Help out
- Issues
- KAFKA-21374: Prevent cross-thread header leakage in global state stores
- KAFKA-21480: Report the end offset of a warm-up task with nothing to restore
- KAFKA-20752: Respect logical schema when formatting dates
- KAFKA-20734: Avoid busy loop while transaction markers wait for an unavailable leader
- MINOR: Speed up transaction index lookup with binary search
- KAFKA-19042 Rewrite MetricsTest from Scala to Java
- MINOR: Avoid per-record leader epoch `Optional` allocation in `CompletedFetch` and `ShareCompletedFetch`
- KAFKA-21371: The docs of partitioner.rack.aware should mention partitioner.ignore.keys and client.rack
- MINOR: Test stale task assignments in StickyTaskAssignor
- KAFKA-21202: Release stateLock before filtering in listTransactionStates
- Docs
- Java not yet supported