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
- MINOR: Narrow remote copy lag validator props to Map<String, ?> and update the upgrade doc for KIP-1241
- KAFKA-19883: [DRAFT] KIP-1289 — Transactional acknowledgments for share groups (state machine + client API + wire schema)
- MINOR: Split GroupMetadataManagerTest into per-group-type files
- 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
- Docs
- Java not yet supported