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 72282ed MINOR: Correctly mark offset expiry in GroupMetadataManager's
OffsetExpired metric
add 4a5155c KAFKA-8868: Generate SubscriptionInfo protocol message (#7248)
No new revisions were added by this update.
Summary of changes:
.gitignore | 1 +
build.gradle | 25 ++
checkstyle/suppressions.xml | 5 +
.../apache/kafka/common/protocol/types/Struct.java | 1 -
.../org/apache/kafka/message/MessageSpecType.java | 5 +-
gradle/spotbugs-exclude.xml | 5 +-
.../internals/StreamsPartitionAssignor.java | 1 +
.../internals/assignment/SubscriptionInfo.java | 385 +++++++--------------
.../resources/common/message/SubscriptionInfo.json | 71 ++++
.../StreamsUpgradeTestIntegrationTest.java | 123 +++++++
.../internals/StreamsPartitionAssignorTest.java | 193 ++++++-----
.../assignment/LegacySubscriptionInfoSerde.java | 276 +++++++++++++++
.../internals/assignment/SubscriptionInfoTest.java | 230 ++++++++++--
.../kafka/streams/tests/StreamsUpgradeTest.java | 77 +++--
14 files changed, 1004 insertions(+), 394 deletions(-)
create mode 100644
streams/src/main/resources/common/message/SubscriptionInfo.json
create mode 100644
streams/src/test/java/org/apache/kafka/streams/integration/StreamsUpgradeTestIntegrationTest.java
create mode 100644
streams/src/test/java/org/apache/kafka/streams/processor/internals/assignment/LegacySubscriptionInfoSerde.java
