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-20292 [5/N]: Add TargetAssignmentRecordsBuilder
- Kip 1340 poc
- KAFKA-20641: ConsumerGroup should clean up the state when a static member temporarily leaves.
- KAFKA-20223: Extended I/O Metrics Collection
- KAFKA-20033: make the __remote_log_metadata topic compact
- MINOR: Reduce unnecessary offset reads during log recovery
- KAFKA-12861: MockProducer NPE with default constructor
- KAFKA-20646: Use Locale.ROOT in String.format() calls in tools/ and sā¦
- KAFKA-13152: Add input.buffer.max.bytes based on KIP-770
- KAFKA-14597: record-e2e-latency-max only considers consumption latencies but not processing delays
- Docs
- Java not yet supported