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 supported302 Subscribers
Add a CodeTriage badge to kafka
Help out
- Issues
- KAFKA-21329: Update outdated steps in SSL docs
- MINOR: Answer rebalance requests by type in testReturnRecordsDuringRebalance
- KAFKA-15853: [5/N] Move DynamicRemoteLogConfig to Java and remove Scala BrokerReconfigurable
- KAFKA-19023: Implement snapshottable timers in the coordinator runtime
- MINOR: Support all JVM KeyFactory algorithms for PEM keys
- KAFKA-21286: Share consumer bounds fetch-buffer wait when no partitions are assigned
- KAFKA-19473: The client does not throw RecordTooLargeException when the Record size exceeds max.partition.fetch.bytes
- KAFKA-21262: Wait for the share group and check the record count in share benchmarks
- KAFKA-21266: Compute the effective min ISR from the target partition
- KAFKA-12585: Stop the heartbeat thread when it fails with a fenced instance id
- Docs
- Java not yet supported