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-20904: Don't bound the poll wait while a fetch is in flight
- MINOR: Use KafkaException instead of RuntimeException in admin result classes
- KAFKA-20455: wait for all producers to send startup_complete before executing system tests
- MINOR: Do not advertise describe APIs on the controller listener
- KAFKA-17929: Handle spurious wakeups while awaiting processable tasks
- KAFKA-14672: Record queue time for expired accumulator batches
- KAFKA-6621: Updated Javadocs for UncaughtExceptionHandler in Kafka Streams
- KAFKA-14605: Change audit log level in StandardAuthorizer
- mm2-fail-fast-offset-loss
- KAFKA-20961: Carry leader epoch history over when replacing the current log with the future log
- Docs
- Java not yet supported