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 supported306 Subscribers
Add a CodeTriage badge to kafka
Help out
- Issues
- 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-20648: Move Processor object and tests to server module
- KAFKA-20649: KIP-1352: Ranges and Range Aggregations in the Kafka Streams DSL
- MINOR: Batch ExpiringErrorCache updates and cleanup
- KAFKA-20602: Bound DLQ topic creation, fix log level and restore interrupt in DeadLetterQueueReporter
- KAFKA-20645: Move LogLoaderTest to storage module
- KAFKA-20646: Use Locale.ROOT in String.format() calls in tools/ and sā¦
- KAFKA-19193: throw ConfigException if rack is empty in rack-aware mode
- KAFKA-19193: trace-log rack-specific load stats in rack-aware mode
- Docs
- Java not yet supported