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 4d6cf3efef1 KAFKA-18913: Start state updater in task manager (#19889)
add e0adec55498 KAFKA-19290: Exploit mapKey optimisation in protocol
requests and responses (wip) (#19815)
No new revisions were added by this update.
Summary of changes:
.../requests/AlterShareGroupOffsetsResponse.java | 11 +-
.../common/requests/ShareAcknowledgeRequest.java | 31 +-
.../common/requests/ShareAcknowledgeResponse.java | 18 +-
.../kafka/common/requests/ShareFetchRequest.java | 40 +-
.../kafka/common/requests/ShareFetchResponse.java | 17 +-
.../message/AlterShareGroupOffsetsResponse.json | 2 +-
.../common/message/ShareAcknowledgeRequest.json | 4 +-
.../common/message/ShareAcknowledgeResponse.json | 2 +-
.../common/message/ShareFetchRequest.json | 4 +-
.../common/message/ShareFetchResponse.json | 2 +-
.../kafka/clients/admin/KafkaAdminClientTest.java | 8 +-
.../clients/consumer/KafkaShareConsumerTest.java | 22 +-
.../internals/ShareConsumeRequestManagerTest.java | 29 +-
.../internals/ShareSessionHandlerTest.java | 2 +-
.../kafka/common/requests/RequestResponseTest.java | 29 +-
.../server/share/SharePartitionManagerTest.java | 6 +-
.../kafka/api/AuthorizerIntegrationTest.scala | 12 +-
.../scala/unit/kafka/server/KafkaApisTest.scala | 576 +++++++++++----------
.../server/ShareFetchAcknowledgeRequestTest.scala | 277 +++++-----
.../coordinator/group/GroupCoordinatorService.java | 4 +-
.../coordinator/group/GroupMetadataManager.java | 2 +-
21 files changed, 557 insertions(+), 541 deletions(-)
