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 supported272 Subscribers
View all SubscribersAdd a CodeTriage badge to kafka
Help out
- Issues
- 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
- KAFKA-9411: Change Name of Default Client ID and Include Java Version
- KAFKA-9406: Modify CreateDelegationTokenOptions Renewers Implementation
- KAFKA-8037: WIP Check deserialization on restoration of local state store from source topics
- KAFKA-9387: Use non JNI LZ4 Hashing for header checksums,
- Docs
- Java not yet supported