You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by da...@apache.org on 2017/07/03 15:04:46 UTC
kafka git commit: MINOR: compatibility tests for streams
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 <en...@gmail.com>
Reviewers: Damian Guy <da...@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 <en...@gmail.com>
Authored: Mon Jul 3 16:04:41 2017 +0100
Committer: Damian Guy <da...@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):
"""