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 supported286 Subscribers
View all SubscribersAdd a CodeTriage badge to kafka
Help out
- Issues
- KAFKA-5876: Add `streamsState()` method to StateStoreProvider
- KAFKA-8120 Getting NegativeArraySizeException when using Kafka Connect to send data to Kafka
- KAFKA-12697: Add EventQueueSize metric to Quorum controller
- [KAFKA-12644] Add Missing Class-Level Javadoc to Exception Classes
- KAFKA-12841-from the provided metadata in client callback in case of ApiException.
- KAFKA-12478: optimize offset reset strategy and fix lose consumer data when add pa…
- KAFKA-12798: Fixing MM2 rebalance timeout issue when source cluster is not available
- KAFKA-12777 Refactor and cleanup AutoTopicCreationManager
- MINOR: Refactored test using parameterization
- KAFKA-10273 Connect Converters should produce actionable error messages
- Docs
- Java not yet supported