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 supported305 Subscribers
Add a CodeTriage badge to kafka
Help out
- Issues
- KAFKA-20644: Fail fast when admin.listeners overlaps listeners
- KAFKA-20641: ConsumerGroup should clean up the state when a static member temporarily leaves.
- KAFKA-20033: make the __remote_log_metadata topic compact
- MINOR: Reduce unnecessary offset reads during log recovery
- KAFKA-12861: MockProducer NPE with default constructor
- KAFKA-20646: Use Locale.ROOT in String.format() calls in tools/ and sā¦
- KAFKA-13152: Add input.buffer.max.bytes based on KIP-770
- KAFKA-20532: Defensive trimming of min.insync.replicas in controller and kafka-topics to tolerate whitespace-contaminated configs
- KAFKA-20072 Make Uuid no-dash behavior opt-in
- KAFKA-20649: KIP-1352: Ranges and Range Aggregations in the Kafka Streams DSL
- Docs
- Java not yet supported