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
View all SubscribersAdd a CodeTriage badge to kafka
Help out
- Issues
- MINOR: Added Compression.wrapForInput method for ByteBufferInputStream.
- 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: extracted the majority of the logic from MemoryRecordsBuilder to an abstract class.
- 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
- MINOR: Split KafkaAdminClientTest into per-domain test classes
- Docs
- Java not yet supported