This is an automated email from the ASF dual-hosted git repository.
schofielaj pushed a change to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git
from 96499029b71 KAFKA-18588 Remove TopicKey.scala (#18624)
add bcbc72e29ba [KAFKA-16720] AdminClient Support for
ListShareGroupOffsets (1/n) (#18571)
No new revisions were added by this update.
Summary of changes:
checkstyle/suppressions.xml | 4 +-
.../java/org/apache/kafka/clients/admin/Admin.java | 22 +
.../kafka/clients/admin/ForwardingAdmin.java | 5 +
.../kafka/clients/admin/KafkaAdminClient.java | 8 +
...ions.java => ListShareGroupOffsetsOptions.java} | 7 +-
.../clients/admin/ListShareGroupOffsetsResult.java | 77 ++
...etsSpec.java => ListShareGroupOffsetsSpec.java} | 31 +-
.../ReadShareGroupStateSummaryRequest.java | 22 +-
.../ReadShareGroupStateSummaryResponse.java | 65 +-
.../kafka/clients/admin/MockAdminClient.java | 5 +
core/src/main/scala/kafka/server/KafkaApis.scala | 19 +-
.../scala/unit/kafka/server/KafkaApisTest.scala | 125 ++++
.../share/persister/DefaultStatePersister.java | 111 ++-
.../share/persister/NoOpShareStatePersister.java | 4 +-
.../server/share/persister/PartitionData.java | 2 +-
.../server/share/persister/PartitionFactory.java | 4 +
...rorData.java => PartitionStateSummaryData.java} | 4 +-
.../share/persister/PersisterStateManager.java | 183 ++++-
.../ReadShareGroupStateSummaryResult.java | 14 +-
.../share/persister/DefaultStatePersisterTest.java | 335 ++++++++-
.../share/persister/PersisterStateManagerTest.java | 773 +++++++++++++++++++++
.../kafka/coordinator/share/ShareCoordinator.java | 10 +
.../coordinator/share/ShareCoordinatorService.java | 130 ++++
.../coordinator/share/ShareCoordinatorShard.java | 100 ++-
.../share/ShareCoordinatorServiceTest.java | 243 ++++++-
.../share/ShareCoordinatorShardTest.java | 60 ++
.../TestingMetricsInterceptingAdminClient.java | 8 +
27 files changed, 2302 insertions(+), 69 deletions(-)
copy
clients/src/main/java/org/apache/kafka/clients/admin/{DeleteRecordsOptions.java
=> ListShareGroupOffsetsOptions.java} (84%)
create mode 100644
clients/src/main/java/org/apache/kafka/clients/admin/ListShareGroupOffsetsResult.java
copy
clients/src/main/java/org/apache/kafka/clients/admin/{ListConsumerGroupOffsetsSpec.java
=> ListShareGroupOffsetsSpec.java} (68%)
copy
server-common/src/main/java/org/apache/kafka/server/share/persister/{PartitionStateErrorData.java
=> PartitionStateSummaryData.java} (87%)
