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-20598: Prevent polling unassigned consumer during ConsumerTask shutdown
- KAFKA-20404: Replace bulk DefaultStateUpdater atomicity excludes with field-level suppressions
- KAFKA-14490: Throw UncheckedIOException from LazyIndex
- KAFKA-20589 : Adding new streams config for restore path to handle memory issues
- KAFKA-20597: Fix prefixScan overflow handling in in-memory state stores
- KAFKA-20530: Log cluster.id at startup phase
- KAFKA-20377: Forward --build-arg flags through ducker-ak
- KAFKA-20599: Improve retry logic in KafkaStatusBackingStore with exponential backoff
- KAFKA-20587: Wait for global store topic partitions in test setup
- KAFKA-967 Use key range in ProducerPerformance
- Docs
- Java not yet supported