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 (78f5da9 -> b62f2a1)
Date Thu, 17 Oct 2019 05:30:00 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 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


Mime
View raw message