KAFKA-10199: Remove main consumer from store changelog reader (#12337)
When store changelog reader is called by a different thread than the stream thread, it can no longer use the main consumer to get committed offsets since consumer is not thread-safe. Instead, we would remove main consumer and leverage on the existing admin client to get committed offsets. Reviewers: Bruno Cadonna <cadonna@apache.org>
显示
- clients/src/main/java/org/apache/kafka/clients/admin/KafkaAdminClient.java 1 个添加, 1 个删除...java/org/apache/kafka/clients/admin/KafkaAdminClient.java
- clients/src/main/java/org/apache/kafka/clients/admin/ListConsumerGroupOffsetsOptions.java 13 个添加, 0 个删除.../kafka/clients/admin/ListConsumerGroupOffsetsOptions.java
- clients/src/main/java/org/apache/kafka/clients/admin/internals/ListConsumerGroupOffsetsHandler.java 12 个添加, 3 个删除...ents/admin/internals/ListConsumerGroupOffsetsHandler.java
- clients/src/test/java/org/apache/kafka/clients/admin/AdminClientTestUtils.java 7 个添加, 0 个删除.../org/apache/kafka/clients/admin/AdminClientTestUtils.java
- clients/src/test/java/org/apache/kafka/clients/admin/KafkaAdminClientTest.java 33 个添加, 0 个删除.../org/apache/kafka/clients/admin/KafkaAdminClientTest.java
- clients/src/test/java/org/apache/kafka/clients/admin/MockAdminClient.java 33 个添加, 5 个删除.../java/org/apache/kafka/clients/admin/MockAdminClient.java
- streams/src/main/java/org/apache/kafka/streams/processor/internals/DefaultStateUpdater.java 1 个添加, 2 个删除...afka/streams/processor/internals/DefaultStateUpdater.java
- streams/src/main/java/org/apache/kafka/streams/processor/internals/StoreChangelogReader.java 39 个添加, 32 个删除...fka/streams/processor/internals/StoreChangelogReader.java
- streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamThread.java 0 个添加, 1 个删除...pache/kafka/streams/processor/internals/StreamThread.java
- streams/src/test/java/org/apache/kafka/streams/processor/internals/DefaultStateUpdaterTest.java 1 个添加, 0 个删除.../streams/processor/internals/DefaultStateUpdaterTest.java
- streams/src/test/java/org/apache/kafka/streams/processor/internals/StandbyTaskTest.java 5 个添加, 3 个删除...he/kafka/streams/processor/internals/StandbyTaskTest.java
- streams/src/test/java/org/apache/kafka/streams/processor/internals/StoreChangelogReaderTest.java 17 个添加, 33 个删除...streams/processor/internals/StoreChangelogReaderTest.java
- streams/src/test/java/org/apache/kafka/streams/processor/internals/StreamTaskTest.java 26 个添加, 1 个删除...che/kafka/streams/processor/internals/StreamTaskTest.java
加载中
想要评论请 注册 或 登录