kafka
kafka copied to clipboard
Mirror of Apache Kafka
In this PR, we corrected the argument order in assertEquals within the connect package.
The actual fix: https://github.com/apache/kafka/pull/20605
Fixes https://issues.apache.org/jira/browse/KAFKA-19010 1. Added the `-XX:+EnableDynamicAgentLoading` JVM argument to the `defaultJvmArgs` 2. Configured Mockito agent in main test task, and applied the same configuration to all test tasks
This PR address KAFKA-19782 by replacing hashset with trie for prefix search. Previously the Authorizer uses character-by-character comparisons to search for prefix patterns to deny within a set of allowed...
https://issues.apache.org/jira/browse/KAFKA-19782 1. Add prefix Trie 2. Add tests 3. fix jmh bemchmarks bugs 4. Change size of bemchmarks cause for 200 000 it leads to call GC before each iteration
Implements [KIP-1219](https://cwiki.apache.org/confluence/display/KAFKA/KIP-1219%3A+Configurations+for+KRaft+Fetch+and+FetchSnapshot+Byte+Size) Adds two new configurations regulate the amount of data fetched by Raft clients. - controller.quorum.fetch.snapshot.max.bytes - controller.quorum.fetch.max.bytes Main design choice is that clients control how much they need...
This PR adds comprehensive unit test coverage for the KafkaCSVMetricsReporter class, which previously had zero test coverage. # Test Results ``` % ./gradlew :core:test --tests kafka.metrics.KafkaCSVMetricsReporterTest > Task :core:test Gradle...
Implement list offset RPC support topic id for protocol and server part
This PR updates the behavior of Admin.incrementalAlterConfigs() to be consistent when invoked using bootstrap servers versus bootstrap controllers. The following changes apply specifically when using a bootstrap controller: 1. Null...
Delete this text and replace it with a detailed description of your change. The PR title and body will become the squashed commit message. If you would like to tag...