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-21321: Let the refiner see a member that joins in the same heartbeat
- MINOR: Pass the configured delay to the echo server in SaslAuthenticatorFailureDelayTest
- KAFKA-21309: Handle Metadata responses without topic names
- KAFKA-21306: Drop tasks already on the new process when a static streams member rejoins
- KAFKA-15606: Clarify completed fetch error handling tests
- MINOR: Acquire RefreshingHttpsJwks lock before entering try block
- KAFKA-21269: Add tests for describing broker configs with raw string values
- KAFKA-21301: Keep existing Streams tasks processing during assignment delays
- KAFKA-21285: Fix dynamic thread counts are lost on restart
- KAFKA-21132: Bound the transaction abort in producer close() by transaction.timeout.ms
- Docs
- Java not yet supported