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 supported286 Subscribers
View all SubscribersAdd a CodeTriage badge to kafka
Help out
- Issues
- KAFKA-15205:Catch InterruptedException when calling ShutDownableThrea…
- KAFKA-14483 Move/Rewrite of LocalLog to storage module.
- MINOR: Optimization of equals methods on implementations of Commands.Handler in shell.command package
- MINOR: optimization of equals and hashcode of GlobalVisitor class
- KAFKA-15204: Re-add throttling rate to KafkaConfig
- KAFKA-12495: IncrementalCooperativeAssignor#handleLostAssignments invokes logic for lost Assignments even when there are no Lost assignments
- KAFKA-15178: Improve ConsumerCoordinator.poll perf
- This adds a default implementation to the KafkaProducer interface to …
- MINOR : Changing the invalid domain name of the test code to a meaningful one
- This adds a default implementation to the KafkaProducer interface to …
- Docs
- Java not yet supported