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-21509: Backort bound size fields in Streams and ListDeserializer deserializers
- KAFKA-21511: Upgrade dependencies with CVE fixes for 3.9
- KAFKA-17965 [1/N]: Refactor request local time tracking
- MINOR: Fix config names that do not exist in docs
- KAFKA-20883,20888: Expose instance id and rack id for streams describe command
- KAFKA-21516: Preserve share group state on initialization retries
- KAFKA-20131; KAFKA-20449: ClassicKafkaConsumer does not clear endOffsetRequested flag on failed LIST_OFFSETS calls
- KAFKA-21503: Add MirrorPartition record type
- KAFKA-21492: Fix task corruption for segmented stores without segments under EOS
- MINOR: Derive the share group state request header version in tests
- Docs
- Java not yet supported