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-21476: Add tests for setRebalanceListener(null)
- KAFKA-20367 Add share-group consumption to Connect sink tasks
- MINOR: Keep a rejected SASL re-authentication failed while its close is delayed
- KAFKA-20665: fix "streams" refiner epoch bump
- KAFKA-21481: Skip transactions from partitions no longer owned
- KAFKA-21469: Shrink NamedCache dirty key set
- KAFKA-21417: Bound decompressed record size in fetch down-conversion
- KAFKA-21372: Build TaskExecutionMetadata and PartitionGroup#nextRecord log messages lazily
- KAFKA-21465: Upgrade Gradle to 9.9.1 (three security fixes, including one critical)
- KAFKA-21445: Add tests to verify the behavior of controlled.shutdown.enable
- Docs
- Java not yet supported