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
View all SubscribersAdd a CodeTriage badge to kafka
Help out
- Issues
- MINOR: Split GroupMetadataManagerTest into per-group-type files
- KAFKA-18948 Move DynamicLogConfig to server module
- KAFKA-20404: Replace bulk TaskManager atomicity exclude with a field-level suppression
- KAFKA-20404: Replace bulk StreamsPartitionAssignor atomicity exclude with field-level suppressions
- MINOR: Move inter-broker NetworkClient factory to server module
- KAFKA-15038: Remove topicIdByPartitionMap from RemoteLogManager
- MINOR: Reduce close delay in testFailureToFenceEpoch
- KAFKA-8073: Fix flaky BaseQuotaTest.testThrottledProducerConsumer
- KAFKA-20404: Replace bulk DefaultStateUpdater atomicity excludes with field-level suppressions
- KAFKA-14490: Throw UncheckedIOException from LazyIndex
- Docs
- Java not yet supported