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 supported305 Subscribers
Add a CodeTriage badge to kafka
Help out
- Issues
- KAFKA-20514: kraft observers should use previous fetch response to decide where to send the next fetch
- MINOR: Optimize `describeConfigs` queries and address cleanups for `ConfigCommand`
- MINOR: Rewrite RaftClusterSnapshotTest from Scala to Java
- introduce private method to remove clones
- KAFKA-20464: Fix topology corruption when ConnectedStoreProviders share a StoreBuilder
- KAFKA-18735: Return null from ConfigEntity.name() for default quotas
- KAFKA-20357: Persist lastProducerEpoch fields for the transaction log.
- KAFKA-16937 Inline Time#waitObject to ProducerMetadata#awaitUpdate
- KAFKA-20454: Prevent offset reset for streams groups in kafka-consumer-groups.sh
- KAFKA-20452: Avoid creating unnecessary empty batches in LogCleaner below the High Watermark
- Docs
- Java not yet supported