This is an automated email from the ASF dual-hosted git repository.
guozhang pushed a change to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git.
from 06e296b KAFKA-8764: LogCleanerManager endless loop while
compacting/cleaning (#7932)
add ed7c071 KAFKA-9365: Add server side change to include consumer group
information within transaction commit (#7897)
No new revisions were added by this update.
Summary of changes:
.../clients/consumer/OffsetCommitCallback.java | 2 +-
.../consumer/internals/AbstractCoordinator.java | 2 +-
.../consumer/internals/ConsumerCoordinator.java | 3 +-
.../kafka/common/requests/JoinGroupRequest.java | 10 +-
.../kafka/common/requests/JoinGroupResponse.java | 4 -
.../common/requests/TxnOffsetCommitResponse.java | 3 +
.../common/message/TxnOffsetCommitRequest.json | 15 ++-
.../common/message/TxnOffsetCommitResponse.json | 9 +-
.../kafka/clients/consumer/KafkaConsumerTest.java | 2 +-
.../internals/AbstractCoordinatorTest.java | 16 +--
.../internals/ConsumerCoordinatorTest.java | 2 +-
.../apache/kafka/common/message/MessageTest.java | 20 +++-
.../kafka/coordinator/group/GroupCoordinator.scala | 51 +++++++---
.../kafka/coordinator/group/GroupMetadata.scala | 4 +-
core/src/main/scala/kafka/server/KafkaApis.scala | 19 ++--
.../group/GroupCoordinatorConcurrencyTest.scala | 5 +-
.../coordinator/group/GroupCoordinatorTest.scala | 107 +++++++++++++++------
17 files changed, 189 insertions(+), 85 deletions(-)
