KAFKA-13043: Implement Admin APIs for offsetFetch batching (#10964)
This implements the AdminAPI portion of KIP-709: https://cwiki.apache.org/confluence/pages/viewpage.action?pageId=173084258 . The request/response protocol changes were implemented in 3.0.0. A new batched API has been introduced to list consumer offsets for different groups. For brokers older than 3.0.0, separate requests are sent for each group. Co-authored-by:Rajini Sivaram <rajinisivaram@googlemail.com> Co-authored-by:
David Jacot <djacot@confluent.io> Reviewers: David Jacot <djacot@confluent.io>, Rajini Sivaram <rajinisivaram@googlemail.com>
显示
- clients/src/main/java/org/apache/kafka/clients/admin/Admin.java 34 个添加, 2 个删除...s/src/main/java/org/apache/kafka/clients/admin/Admin.java
- clients/src/main/java/org/apache/kafka/clients/admin/KafkaAdminClient.java 6 个添加, 5 个删除...java/org/apache/kafka/clients/admin/KafkaAdminClient.java
- clients/src/main/java/org/apache/kafka/clients/admin/ListConsumerGroupOffsetsOptions.java 12 个添加, 2 个删除.../kafka/clients/admin/ListConsumerGroupOffsetsOptions.java
- clients/src/main/java/org/apache/kafka/clients/admin/ListConsumerGroupOffsetsResult.java 49 个添加, 7 个删除...e/kafka/clients/admin/ListConsumerGroupOffsetsResult.java
- clients/src/main/java/org/apache/kafka/clients/admin/ListConsumerGroupOffsetsSpec.java 79 个添加, 0 个删除...che/kafka/clients/admin/ListConsumerGroupOffsetsSpec.java
- clients/src/main/java/org/apache/kafka/clients/admin/internals/AdminApiDriver.java 2 个添加, 1 个删除.../apache/kafka/clients/admin/internals/AdminApiDriver.java
- clients/src/main/java/org/apache/kafka/clients/admin/internals/CoordinatorStrategy.java 4 个添加, 0 个删除...he/kafka/clients/admin/internals/CoordinatorStrategy.java
- clients/src/main/java/org/apache/kafka/clients/admin/internals/ListConsumerGroupOffsetsHandler.java 74 个添加, 54 个删除...ents/admin/internals/ListConsumerGroupOffsetsHandler.java
- clients/src/main/java/org/apache/kafka/common/requests/OffsetFetchResponse.java 7 个添加, 3 个删除...org/apache/kafka/common/requests/OffsetFetchResponse.java
- clients/src/test/java/org/apache/kafka/clients/admin/AdminClientTestUtils.java 8 个添加, 4 个删除.../org/apache/kafka/clients/admin/AdminClientTestUtils.java
- clients/src/test/java/org/apache/kafka/clients/admin/KafkaAdminClientTest.java 185 个添加, 21 个删除.../org/apache/kafka/clients/admin/KafkaAdminClientTest.java
- clients/src/test/java/org/apache/kafka/clients/admin/MockAdminClient.java 11 个添加, 5 个删除.../java/org/apache/kafka/clients/admin/MockAdminClient.java
- clients/src/test/java/org/apache/kafka/clients/admin/internals/ListConsumerGroupOffsetsHandlerTest.java 288 个添加, 20 个删除.../admin/internals/ListConsumerGroupOffsetsHandlerTest.java
- clients/src/test/java/org/apache/kafka/clients/consumer/KafkaConsumerTest.java 5 个添加, 1 个删除.../org/apache/kafka/clients/consumer/KafkaConsumerTest.java
- clients/src/test/java/org/apache/kafka/clients/consumer/internals/ConsumerCoordinatorTest.java 17 个添加, 9 个删除...a/clients/consumer/internals/ConsumerCoordinatorTest.java
- core/src/main/scala/kafka/admin/ConsumerGroupCommand.scala 4 个添加, 4 个删除core/src/main/scala/kafka/admin/ConsumerGroupCommand.scala
- core/src/test/scala/unit/kafka/admin/ConsumerGroupServiceTest.scala 14 个添加, 8 个删除...est/scala/unit/kafka/admin/ConsumerGroupServiceTest.scala
- core/src/test/scala/unit/kafka/server/RequestQuotaTest.scala 1 个添加, 1 个删除core/src/test/scala/unit/kafka/server/RequestQuotaTest.scala
- streams/src/main/java/org/apache/kafka/streams/processor/internals/StoreChangelogReader.java 7 个添加, 5 个删除...fka/streams/processor/internals/StoreChangelogReader.java
- streams/src/test/java/org/apache/kafka/streams/processor/internals/StoreChangelogReaderTest.java 6 个添加, 5 个删除...streams/processor/internals/StoreChangelogReaderTest.java
加载中
想要评论请 注册 或 登录