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-21188: Prototype broker-provided topic metadata for Streams task assignment
- MINOR: Let ConsumerPerfRebListener own its join time fields
- KAFKA-21440: Share consumer keeps fetching from the old leader after KAFKA_STORAGE_ERROR
- KAFKA-21434: Include C++ runtime for RocksDB in JVM Docker image
- KAFKA-21409: Switching to a subscription regex that matches no topic doesn't trigger rebalance
- KAFKA-21338: Use exponential backoff with jitter for internal topic retries in InternalTopicManager
- MINOR: Add missing @Override annotations in clients
- KAFKA-21435: Do not close MirrorCheckpointTask stores while they are still starting
- MINOR: Enable MirrorStateMessageFormatter round trip
- KAFKA-21439:Add share consumer test for records written after unclean leader election
- Docs
- Java not yet supported