This is an automated email from the ASF dual-hosted git repository.
dajac pushed a change to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git
from b4b73c604b7 KAFKA-19245: Updated default locks config for share group
(#19705)
add d154a314e74 KAFKA-14691; Add TopicId to OffsetFetch API (#19515)
No new revisions were added by this update.
Summary of changes:
.../internals/ListConsumerGroupOffsetsHandler.java | 2 +-
.../consumer/internals/CommitRequestManager.java | 4 +-
.../consumer/internals/ConsumerCoordinator.java | 2 +-
.../kafka/common/requests/OffsetFetchRequest.java | 145 +++++++---
.../common/message/OffsetFetchRequest.json | 9 +-
.../common/message/OffsetFetchResponse.json | 9 +-
.../apache/kafka/common/message/MessageTest.java | 6 +-
.../common/requests/OffsetFetchRequestTest.java | 31 +-
.../kafka/common/requests/RequestResponseTest.java | 18 +-
core/src/main/scala/kafka/server/KafkaApis.scala | 80 +++++-
.../kafka/api/AuthorizerIntegrationTest.scala | 6 +-
.../server/ConsumerProtocolMigrationTest.scala | 44 +--
.../server/GroupCoordinatorBaseRequestTest.scala | 92 +++---
.../scala/unit/kafka/server/KafkaApisTest.scala | 314 ++++++++++++++++++---
.../unit/kafka/server/OffsetFetchRequestTest.scala | 203 ++++++++-----
.../scala/unit/kafka/server/RequestQuotaTest.scala | 2 +-
.../kafka/server/TxnOffsetCommitRequestTest.scala | 17 +-
.../coordinator/group/OffsetMetadataManager.java | 11 +-
.../group/OffsetMetadataManagerTest.java | 38 +++
19 files changed, 750 insertions(+), 283 deletions(-)
