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 supported307 Subscribers
Add a CodeTriage badge to kafka
Help out
- Issues
- Add support to set the target timezone when we use the TimestampConverter.
- KAFKA-19932: adding handling of OOM and avoiding wrapped as timeout
- Implementing KIP-977
- KAFKA-17302: ReplicaFetcher changes for fetching from tiered offset
- KAFKA-14405: Log a warning when users attempt to set a config controlled by Streams
- MINOR: Remove the flaky streams admin api test - describe streams group with short timeout
- KAFKA-19893: Reduce tiered storage redundancy with delayed upload (KIP-1241)
- KAFKA-17521: Avoid WARN on cleanup when state directory only contains process metadata.
- KAFKA-19909: Add rack awareness assignment to UniformHomogeneousAssignmentBuilder
- KAFKA-19761 Gradle Shadow plugin version upgrade: 8.3.9 -->> 9.3.1
- Docs
- Java not yet supported