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 supported303 Subscribers
View all SubscribersAdd a CodeTriage badge to kafka
Help out
- Issues
- MINOR: Write log differently according to the size of missingListenerPartitions
- KAFKA-13361: Support fine-grained compression options
- KAFKA-13342: LeaderAndIsrRequest should not be sent for topic queued for deletion
- KAFKA-10865: Log transformed record in WorkerSinkTask
- KAFKA-12465: Logic about inconsistent cluster id
- KAFKA-13255 Fixed code so user can use config.properties.exclude to exclude prope…
- Make test-utils MockTime more flexible
- KAFKA-10900: Add metrics enumerated in KIP-630
- smt to rename schemas based on regex
- Make classpath smaller
- Docs
- Java not yet supported