kafka
kafka copied to clipboard
apache
Mirror of Apache Kafka
jira: https://issues.apache.org/jira/browse/KAFKA-18279 see discussion: https://github.com/apache/kafka/pull/17861#issuecomment-2547515965 This PR will add a post-commit job to trunk branch - it should run check and test for clients and streams module under JDK 11.
### Tasks: - [x] Add a custom [SelectorProvider](clients/src/main/java/org/apache/kafka/common/network/SelectorProvider.java). - [x] Update [Selector](clients/src/main/java/org/apache/kafka/common/network/Selector.java) to utilize the custom SelectorProvider. ### Changes: The [SelectorProvider](clients/src/main/java/org/apache/kafka/common/network/SelectorProvider.java) fixes an issue where the static method `Selector.open()` would...
[WIP] KAFKA-18877: Add an mechanism to find cases where we accessed variables from the wrong thread.
JIRA: KAFKA-18877 This PR is plan to add a "safe access" interface to the `*ControlManager` class to make sure they don't expose the unsafe methods.
JIRA: KAFKA-18379 For further details, please refer to [KIP-996](https://cwiki.apache.org/confluence/pages/viewpage.action?pageId=272927537#KIP996:PreVote-ResignedStatechanges) and https://github.com/apache/kafka/pull/18240#discussion_r1899341945. In short, this PR adds a check for the transition from the resigned state to other states to prevent...
We are removing some of the previously added public APIs until KIP-939 is ready to use.
Migrate ControllerMutationQuotaManager to Java implementation and move to server module, including ClientQuotaManager and associated files. Reviewers: PoAn Yang [[email protected]](mailto:[email protected]), Ken Huang [[email protected]](mailto:[email protected]), TengYao Chi [[email protected]](mailto:[email protected]), Chia-Ping Tsai [[email protected]](mailto:[email protected])
Improve fairness of partition fetch order when clients fetch data to avoid partition starvation. Randomly shuffles the `readPartitionInfo` sequence before iterating over it in the log read process. This change...
JIRA: KAFKA-18185 This is a follow-up of #17614 The patch is to remove the `internal.leave.group.on.close` config.
There’s a difference in the two consumers’ `pollForFetches()` methods in this case: `ClassicKafkaConsumer` doesn't block waiting for data in the fetch buffer, but `AsyncKafkaConsumer` does. In `ClassicKafkaConsumer.pollForFetches()`, after enqueuing the...
this is a follow-up for https://github.com/apache/kafka/pull/19685 The timeout issue in `AsyncConsumer#unsubscribe` was fixed by https://github.com/apache/kafka/pull/19779. As a result, the test `GroupAuthorizerIntegrationTest#testConsumeUnsubscribeWithoutGroupPermission` should now retain its original behavior as expected prior...