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
Add a CodeTriage badge to kafka
Help out
- Issues
- MINOR: use ConfigDef.parseType for rack aware tag
- KAFKA-21118: Replace temp file handler with JUnit 5 @TempDir in connect tests
- KAFKA-18744: reuse LoginCallbackHandler on Kerberos re-login
- MINOR: Add Protobuf message formatter for kafka-console-consumer
- KAFKA-20981: fail on an unknown status code in the Streams heartbeat response
- MINOR: Stable flaky e2e test `share_consumer_dlq_tiered_storage_test` (WIP)
- KAFKA-20985: Keep static member id when LeaveGroup is suppressed
- KAFKA-15976: Allow specifying initial offsets while creating connectors
- KAFKA-20887: Fix IQ key hashing during streams-protocol rebalance
- KAFKA-20901: Enforce cordoned log directories configured with relative paths
- Docs
- Java not yet supported