kafka
kafka copied to clipboard
apache
Mirror of Apache Kafka
JIRA: [KAFKA-17668](https://issues.apache.org/jira/browse/KAFKA-17668) > Both methods can be rewrite by scala 2.13 methods Since `maxOverCleanerThreads` does not have a corresponding unit test, I have added a unit test to ensure the...
JIRA: [KAFKA-17456](https://issues.apache.org/jira/browse/KAFKA-17456) > The incorrect order could lead to flaky (see [KAFKA-17092](https://issues.apache.org/jira/browse/KAFKA-17092) and [KAFKA-17395](https://issues.apache.org/jira/browse/KAFKA-17395)). It would be nice that we fix all of them. ### Committer Checklist (excluded from commit...
JIRA: [KAFKA-17811](https://issues.apache.org/jira/browse/KAFKA-17811) This is sub-task to drop broker and tools support for Java 11. ### Committer Checklist (excluded from commit message) - [ ] Verify design and implementation - [...
jira: https://issues.apache.org/jira/browse/KAFKA-17037 ### Committer Checklist (excluded from commit message) - [ ] Verify design and implementation - [ ] Verify test coverage and CI build status - [ ] Verify...
Jira: https://issues.apache.org/jira/browse/KAFKA-16816 ### Committer Checklist (excluded from commit message) - [ ] Verify design and implementation - [ ] Verify test coverage and CI build status - [ ] Verify...
Following test cases only add describe types to group name, but don't use it as command arguments. - testDescribeExistingGroupWithNoMembers - testDescribeAllExistingGroups - testDescribeExistingGroup ### Committer Checklist (excluded from commit message)...
Removed --zookeeper option and logic from ConfigCommand Build successful with Java 21 with cmd `./gradlew clean build -x test`
Add following metrics to AsyncKafkaConsumer: * time-between-network-thread-poll-avg * time-between-network-thread-poll-max * application-event-queue-size * application-event-queue-time-avg * application-event-queue-time-max * application-event-queue-processing-time-avg * application-event-queue-processing-time-max * unsent-requests-queue-size * unsent-requests-queue-time-avg * unsent-requests-queue-time-max * background-event-queue-size * background-event-queue-time-avg *...
When committing all consumed offsets (sync, async, or on close), the new consumer retrieves the offsets from subscriptionState.allConsumed() in the app thread. We should consider to retrieve the allConsumed in...
A tiny fix to a single protocol JSON which was recently updated under KAFKA-14562. It seems to erroneously use strings where bools appear to be the right type. ### Committer...
