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 supported286 Subscribers
View all SubscribersAdd a CodeTriage badge to kafka
Help out
- Issues
- KAFKA-4083: prevent changing replication factor via partition reassignment
- KIP-731 Connect per-task record rate limiting
- KAFKA-12713: Report the real fetch latency by removing the wait-time in purgatory.
- MINOR: Fix error log for bounce broker
- BlockingConnectorTest improvements to verify Connectors and Tasks are successfully deleted
- KAFKA-12605 - make GZIP decompression use BufferSupplier
- KAFKA-806: Index may not always observe log.index.interval.bytes
- MINOR: Add some metrics names
- Fix minor bugs in the existing documentation
- KAFKA-5761: support ByteBuffer as value in ProducerRecord and avoid redundant serialization when it's used
- Docs
- Java not yet supported