kafka
kafka copied to clipboard
apache
Mirror of Apache Kafka
The description is inconsistent with method `leader()`. After checking the code, we always use pass `null` to `TopicPartitionInfo` instead of `noNode` The current description is inconsistent with the `leader()` method....
The Kafka website is hosted in a separate repository than the Kafka code. The files versioned in the kafka-site repository are generated as part of the version release process and...
Add `bootstrapController` to Kafka-broker-apis tool. This change includes remove ConsumerNetworkClient and using its underlayer NetworkClient. Also implemented the specific MetadataUpder for this tool.
These are the new interfaces detailed in KIP-1035: "StateStore managed changelog offsets". This PR introduces the interfaces changes, but makes otherwise no consequential behavioural changes. Outside of `StateStore.java`, _all_ changes...
## Motivation This pull request addresses a common pain point for new users learning how to develop applications with Kafka clients: testing without relying on a full Kafka cluster. The...
Update Docs to explain how to use suppress() in more details
Adding docs into the requested document, but pls let me know if it needs to be put (also) anywhere else, or in another shape, thank u
Integrates the [forbidden-apis](https://github.com/policeman-tools/forbidden-apis) Gradle plugin to scan bytecode for invocations of unsafe or deprecated API methods. ## Changes - Add forbidden-apis plugin (v3.10) to gradle build - Configure with `jdk-unsafe`...
Replace MD5 with SHA-256 for FIPS 140-3 compliance in Log Cleaner.
See https://github.com/apache/kafka/pull/20614#pullrequestreview-3379156676 Refactor nullable types as a subclass of non-nullable types.
