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 supported285 Subscribers
View all SubscribersAdd a CodeTriage badge to kafka
Help out
- Issues
- KAFKA-9506: Fix JmxReporter corner cases and optimize
- MINOR: Better naming for variables denoting a forced unclean leader election
- KAFKA-9489 Remove @InterfaceStability.Evolving from AdminClient
- update example reassign file to include log_dirs configuration
- KAFKA-9456: Add support for printing all the latencies
- KAFKA-9425: InFlightRequests Class Uses Thread-Safe Counter Non-Threa…
- KAFKA-9358 Explicitly unregister brokers and controller from ZK
- KAFKA-9436: New Kafka Connect SMT for plainText => Struct(or Map)
- KAFKA-9415: Review Thread Interrupt Usage
- KAFKA-9042: Auto infer external topic partitions in stream reset tool
- Docs
- Java not yet supported