You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by gu...@apache.org on 2019/10/17 05:30:00 UTC
[kafka] branch trunk updated (78f5da9 -> b62f2a1)

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 78f5da9  KAFKA-9053: AssignmentInfo#encode hardcodes the LATEST_SUPPORTED_VERSION (#7537)
     add b62f2a1  KAFKA-8496: System test for KIP-429 upgrades and compatibility (#7529)

No new revisions were added by this update.

Summary of changes:
 .../assignment/AssignorConfiguration.java          |   4 +-
 .../StreamsUpgradeToCooperativeRebalanceTest.java  | 136 ++++++++++++++
 ... StreamsUpgradeToCooperativeRebalanceTest.java} |  95 ++++------
 .../StreamsUpgradeToCooperativeRebalanceTest.java} |  94 ++++-----
 .../StreamsUpgradeToCooperativeRebalanceTest.java  |  85 +++++++++
 .../StreamsUpgradeToCooperativeRebalanceTest.java  |  87 +++++++++
 .../StreamsUpgradeToCooperativeRebalanceTest.java  | 136 ++++++++++++++
 .../StreamsUpgradeToCooperativeRebalanceTest.java  | 136 ++++++++++++++
 .../StreamsUpgradeToCooperativeRebalanceTest.java  | 136 ++++++++++++++
 .../StreamsUpgradeToCooperativeRebalanceTest.java  | 136 ++++++++++++++
 .../StreamsUpgradeToCooperativeRebalanceTest.java  | 136 ++++++++++++++
 .../StreamsUpgradeToCooperativeRebalanceTest.java  | 125 ++++++++++++
 tests/kafkatest/services/streams.py                |  85 +++++++++
 .../streams_cooperative_rebalance_upgrade_test.py  | 209 +++++++++++++++++++++
 tests/kafkatest/version.py                         |   1 +
 15 files changed, 1487 insertions(+), 114 deletions(-)
 create mode 100644 streams/src/test/java/org/apache/kafka/streams/tests/StreamsUpgradeToCooperativeRebalanceTest.java
 copy streams/upgrade-system-tests-0100/src/test/java/org/apache/kafka/streams/tests/{StreamsUpgradeTest.java => StreamsUpgradeToCooperativeRebalanceTest.java} (50%)
 copy streams/{upgrade-system-tests-0100/src/test/java/org/apache/kafka/streams/tests/StreamsUpgradeTest.java => upgrade-system-tests-0101/src/test/java/org/apache/kafka/streams/tests/StreamsUpgradeToCooperativeRebalanceTest.java} (50%)
 create mode 100644 streams/upgrade-system-tests-0102/src/test/java/org/apache/kafka/streams/tests/StreamsUpgradeToCooperativeRebalanceTest.java
 create mode 100644 streams/upgrade-system-tests-0110/src/test/java/org/apache/kafka/streams/tests/StreamsUpgradeToCooperativeRebalanceTest.java
 create mode 100644 streams/upgrade-system-tests-10/src/test/java/org/apache/kafka/streams/tests/StreamsUpgradeToCooperativeRebalanceTest.java
 create mode 100644 streams/upgrade-system-tests-11/src/test/java/org/apache/kafka/streams/tests/StreamsUpgradeToCooperativeRebalanceTest.java
 create mode 100644 streams/upgrade-system-tests-20/src/test/java/org/apache/kafka/streams/tests/StreamsUpgradeToCooperativeRebalanceTest.java
 create mode 100644 streams/upgrade-system-tests-21/src/test/java/org/apache/kafka/streams/tests/StreamsUpgradeToCooperativeRebalanceTest.java
 create mode 100644 streams/upgrade-system-tests-22/src/test/java/org/apache/kafka/streams/tests/StreamsUpgradeToCooperativeRebalanceTest.java
 create mode 100644 streams/upgrade-system-tests-23/src/test/java/org/apache/kafka/streams/tests/StreamsUpgradeToCooperativeRebalanceTest.java
 create mode 100644 tests/kafkatest/tests/streams/streams_cooperative_rebalance_upgrade_test.py