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 supported307 Subscribers
Add a CodeTriage badge to kafka
Help out
- Issues
- KAFKA-17103: MockClient tight loops when no metadata is present in KafkaProducerTest
- KAFKA-19687: MetaDataShell log error message for SNAPSHOT_HEADER and SNAPSHOT_FOOTER
- KAFKA-19833: Refactor Nullable Types to Use a Unified Pattern
- KAFKA-19967: Reduce GC pressure in tiered storage read path using direct memory buffers
- MINOR: Improve the `KAFKA_HEAP_OPTS` definition while run `kafka-server-start.bat` Batch
- KAFKA-19122: updateClusterMetadata receives multiples PartitionInfo
- KAFKA-19086: Add support for microsecond precision for Connect
- KAFKA-16768: SocketServer leaks accepted SocketChannel instances due to race condition
- MINOR Metrics: use String.intern() to reduce duplicate metric names and tags
- POC: conditional creation of internal topics in Kafka Connect
- Docs
- Java not yet supported