kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From damian...@apache.org
Subject kafka git commit: MINOR: compatibility tests for streams
Date Mon, 03 Jul 2017 15:04:46 GMT
Repository: kafka
Updated Branches:
  refs/heads/trunk 2c6e9a965 -> cbafc08a5


MINOR: compatibility tests for streams

Update system tests to make use of the newly released 0.11 version.

Add on to https://github.com/apache/kafka/pull/3454

Author: Eno Thereska <eno.thereska@gmail.com>

Reviewers: Damian Guy <damian.guy@gmail.com>

Closes #3479 from enothereska/minor-compatibility-tests


Project: http://git-wip-us.apache.org/repos/asf/kafka/repo
Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/cbafc08a
Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/cbafc08a
Diff: http://git-wip-us.apache.org/repos/asf/kafka/diff/cbafc08a

Branch: refs/heads/trunk
Commit: cbafc08a5f25df58d33093b2e6015e8c49fefdea
Parents: 2c6e9a9
Author: Eno Thereska <eno.thereska@gmail.com>
Authored: Mon Jul 3 16:04:41 2017 +0100
Committer: Damian Guy <damian.guy@gmail.com>
Committed: Mon Jul 3 16:04:41 2017 +0100

----------------------------------------------------------------------
 .../tests/streams/streams_broker_compatibility_test.py          | 4 +++-
 tests/kafkatest/tests/streams/streams_upgrade_test.py           | 5 ++++-
 2 files changed, 7 insertions(+), 2 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/kafka/blob/cbafc08a/tests/kafkatest/tests/streams/streams_broker_compatibility_test.py
----------------------------------------------------------------------
diff --git a/tests/kafkatest/tests/streams/streams_broker_compatibility_test.py b/tests/kafkatest/tests/streams/streams_broker_compatibility_test.py
index c4b554e..1405c34 100644
--- a/tests/kafkatest/tests/streams/streams_broker_compatibility_test.py
+++ b/tests/kafkatest/tests/streams/streams_broker_compatibility_test.py
@@ -21,7 +21,7 @@ from kafkatest.services.kafka import KafkaService
 from kafkatest.services.streams import StreamsBrokerCompatibilityService
 from kafkatest.services.verifiable_consumer import VerifiableConsumer
 from kafkatest.services.zookeeper import ZookeeperService
-from kafkatest.version import DEV_BRANCH, LATEST_0_10_2, LATEST_0_10_1, LATEST_0_10_0, LATEST_0_9,
LATEST_0_8_2, KafkaVersion
+from kafkatest.version import DEV_BRANCH, LATEST_0_11_0, LATEST_0_10_2, LATEST_0_10_1, LATEST_0_10_0,
LATEST_0_9, LATEST_0_8_2, KafkaVersion
 
 
 class StreamsBrokerCompatibility(Test):
@@ -55,6 +55,7 @@ class StreamsBrokerCompatibility(Test):
     def setUp(self):
         self.zk.start()
 
+   
     @parametrize(broker_version=str(LATEST_0_10_2))
     @parametrize(broker_version=str(LATEST_0_10_1))
     def test_fail_fast_on_incompatible_brokers_if_eos_enabled(self, broker_version):
@@ -72,6 +73,7 @@ class StreamsBrokerCompatibility(Test):
 
         self.kafka.stop()
 
+    @parametrize(broker_version=str(LATEST_0_11_0))
     @parametrize(broker_version=str(LATEST_0_10_2))
     @parametrize(broker_version=str(LATEST_0_10_1))
     def test_compatible_brokers_eos_disabled(self, broker_version):

http://git-wip-us.apache.org/repos/asf/kafka/blob/cbafc08a/tests/kafkatest/tests/streams/streams_upgrade_test.py
----------------------------------------------------------------------
diff --git a/tests/kafkatest/tests/streams/streams_upgrade_test.py b/tests/kafkatest/tests/streams/streams_upgrade_test.py
index 16a8489..81b7ffe 100644
--- a/tests/kafkatest/tests/streams/streams_upgrade_test.py
+++ b/tests/kafkatest/tests/streams/streams_upgrade_test.py
@@ -19,7 +19,7 @@ from ducktape.mark import parametrize, ignore
 from kafkatest.services.kafka import KafkaService
 from kafkatest.services.zookeeper import ZookeeperService
 from kafkatest.services.streams import StreamsSmokeTestDriverService, StreamsSmokeTestJobRunnerService
-from kafkatest.version import LATEST_0_10_1, LATEST_0_10_2, DEV_BRANCH, KafkaVersion
+from kafkatest.version import LATEST_0_10_1, LATEST_0_10_2, LATEST_0_11_0, DEV_BRANCH, KafkaVersion
 import time
 
 
@@ -80,6 +80,9 @@ class StreamsUpgradeTest(Test):
     @cluster(num_nodes=6)
     @parametrize(from_version=str(LATEST_0_10_1), to_version=str(DEV_BRANCH))
     @parametrize(from_version=str(LATEST_0_10_2), to_version=str(DEV_BRANCH))
+    @parametrize(from_version=str(LATEST_0_10_1), to_version=str(LATEST_0_11_0))
+    @parametrize(from_version=str(LATEST_0_10_2), to_version=str(LATEST_0_11_0))
+    @parametrize(from_version=str(LATEST_0_11_0), to_version=str(LATEST_0_10_2))
     @parametrize(from_version=str(DEV_BRANCH), to_version=str(LATEST_0_10_2))
     def test_upgrade_downgrade_streams(self, from_version, to_version):
         """


Mime
View raw message