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
- Add ConsumerGroupCommand to delete static members
- MINOR: Fix misleading doc for replication quota
- KAFKA-10431: Sequential selection of payload in ProducerPerformance
- MINOR: add epoch lineage checks to system tests
- break when dst is full so that unwrap isn't called when appreadbuffer…
- Allow replace all for RegexRouter
- KAFKA-9941;WorkerSinkTask:When a record triggers a RetriableException and the retry is processed successfully, its offset does not commit.
- KAFKA-10385 - Remove no print stat when on detailed stat mode on Consumer Perf
- MINOR KAFKA-10382 - MockProducer is not ThreadSafe, ideally it should be as the implementation it mocks is
- MINOR: supervise TransactionalMessageCopier producer
- Docs
- Java not yet supported