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
- Minor:Fix method scalaDoc in DelayedFetch.scala
- KAFKA-13838: Improve the poll method of ConsumerNetworkClient
- MINOR:Fix test in ReplicaManagerTest.scala
- KAFKA-12319: Change calculation of window size used to calculate `Rate`
- KAFKA-12738: implement exponential backoff for tasks
- KAFKA-13810 Document behavior of KafkaProducer.flush() w.r.t callbacks
- KAFKA-13818: Add generation to consumer assignor logs
- KIP-829: (console consumer) add print.topic property
- KAFKA-13768: Don't mark expired batches as unresolved when using transactional producer
- KAFKA-12908: Load raft snapshot heuristic (WIP)
- Docs
- Java not yet supported