This is an automated email from the ASF dual-hosted git repository.
lucasbru pushed a change to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git
from 8eacd815140 KAFKA-19698 Streams package assertEquals arguments
adjustments (#20573)
add 69dd4c8c58e KAFKA-19779: Add partitions to offset commit validation
[1/N] (#20714)
No new revisions were added by this update.
Summary of changes:
.../group/CommitPartitionValidator.java | 23 +-
.../org/apache/kafka/coordinator/group/Group.java | 4 +-
.../coordinator/group/GroupMetadataManager.java | 2 +-
.../coordinator/group/OffsetMetadataManager.java | 60 +++--
.../coordinator/group/classic/ClassicGroup.java | 8 +-
.../group/modern/consumer/ConsumerGroup.java | 9 +-
.../coordinator/group/modern/share/ShareGroup.java | 3 +-
.../coordinator/group/streams/StreamsGroup.java | 9 +-
.../group/OffsetMetadataManagerTest.java | 290 ++++++++++++++++++++-
9 files changed, 360 insertions(+), 48 deletions(-)
copy
server/src/main/java/org/apache/kafka/server/share/ShareGroupListener.java =>
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/CommitPartitionValidator.java
(59%)
