kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From guozh...@apache.org
Subject [kafka] branch trunk updated (72282ed -> 4a5155c)
Date Fri, 01 Nov 2019 17:04:37 GMT
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


Mime
View raw message