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 supported306 Subscribers
Add a CodeTriage badge to kafka
Help out
- Issues
- KAFKA-21054: Fix vacuous timeout tests in InternalTopicManagerTest
- KAFKA-21022: Treat logs missing topic ID as stray replicas in findStr…
- KAFKA-20998: Add balanced task assignor for streams groups
- MINOR: Warn when Connect sink tasks use the consumer group protocol
- KAFKA-19327: Batch topic creation requests in MirrorSourceConnector
- KAFKA-21049: Prevent async consumer busy loop with zero retry backoff
- KAFKA-21120: Replace temp file handler with JUnit 5 @TempDir in clients and connect tests
- KAFKA-21034: Wipe the global state directory when the store is corrupted
- MINOR: Migrate User SCRAM Credentials admin integration tests to Java
- KAFKA-21043: Do not share LoginManager across class loaders
- Docs
- Java not yet supported