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 9cb271f1e17 KAFKA-18654[2/2]: Transction V2 retry add partitions on
the server side when handling produce request. (#18810)
add 952113e8e0e KAFKA-16720: Support multiple groups in
DescribeShareGroupOffsets RPC (#18834)
No new revisions were added by this update.
Summary of changes:
.../clients/admin/ListShareGroupOffsetsSpec.java | 2 +
.../internals/ListShareGroupOffsetsHandler.java | 144 +++++++++++++------
.../requests/DescribeShareGroupOffsetsRequest.java | 51 +++----
.../DescribeShareGroupOffsetsResponse.java | 51 +++++--
.../message/DescribeShareGroupOffsetsRequest.json | 19 +--
.../message/DescribeShareGroupOffsetsResponse.json | 47 +++---
.../kafka/clients/admin/KafkaAdminClientTest.java | 128 ++++++++++++++---
.../kafka/common/requests/RequestResponseTest.java | 157 +++++++++++----------
.../group/GroupCoordinatorAdapter.scala | 4 +-
core/src/main/scala/kafka/server/KafkaApis.scala | 62 +++++---
.../group/GroupCoordinatorAdapterTest.scala | 2 +-
.../scala/unit/kafka/server/KafkaApisTest.scala | 140 +++++++++++++++---
.../kafka/coordinator/group/GroupCoordinator.java | 14 +-
.../coordinator/group/GroupCoordinatorService.java | 90 +++++++-----
.../group/GroupCoordinatorServiceTest.java | 110 +++++++++------
15 files changed, 692 insertions(+), 329 deletions(-)
