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 supported297 Subscribers
View all SubscribersAdd a CodeTriage badge to kafka
Help out
- Issues
- MINOR: convert GssapiAuthenticationTest to KRaft
- Add Kraft migration revert cleanup steps
- [WIP] KAFKA-17928: Make remote log manager thread-pool configs dynamic
- Integrate Streams membership manager with stream thread
- KAFKA-17783: Adding listeners to remove share partition on partition changes
- MINOR: Update the list of collaborators based on the number of commit…
- KAFKA-17904: Flaky testMultiConsumerSessionTimeoutOnClose
- [WIP] KAFKA-17893: Support record keys in the foreignKeyExtractor argument of KTable foreign join
- KAFKA-10532: Handle state updater failed tasks
- KAFKA-17949: Introduce GroupState and replace ShareGroupState
- Docs
- Java not yet supported