kafka git commit: KAFKA-4165; Add 0.10.0.1 as a source for compatibility tests
Repository: kafka
Updated Branches:
refs/heads/0.10.1 41b12a6ad -> 017defcd1
KAFKA-4165; Add 0.10.0.1 as a source for compatibility tests
Author: Jason Gustafson
Reviewers: Ismael Juma
Closes #1959 from hachikuji/KAFKA-4165
(cherry picked from commit b3eef7bc72743b006d068ae6c3edf71d413ef433)
Signed-off-by: Jason Gustafson
Project: http://git-wip-us.apache.org/repos/asf/kafka/repo
Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/017defcd
Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/017defcd
Diff: http://git-wip-us.apache.org/repos/asf/kafka/diff/017defcd
Branch: refs/heads/0.10.1
Commit: 017defcd13061c5c8c4b55696b31e105da3cc27a
Parents: 41b12a6
Author: Jason Gustafson
Authored: Tue Oct 4 11:12:56 2016 -0700
Committer: Jason Gustafson
Committed: Tue Oct 4 11:13:07 2016 -0700
--
.../tests/core/compatibility_test_new_broker_test.py | 3 ++-
tests/kafkatest/tests/core/upgrade_test.py| 7 +++
2 files changed, 5 insertions(+), 5 deletions(-)
--
http://git-wip-us.apache.org/repos/asf/kafka/blob/017defcd/tests/kafkatest/tests/core/compatibility_test_new_broker_test.py
--
diff --git a/tests/kafkatest/tests/core/compatibility_test_new_broker_test.py
b/tests/kafkatest/tests/core/compatibility_test_new_broker_test.py
index 85fc9ae..7fe875d 100644
--- a/tests/kafkatest/tests/core/compatibility_test_new_broker_test.py
+++ b/tests/kafkatest/tests/core/compatibility_test_new_broker_test.py
@@ -22,7 +22,7 @@ from kafkatest.services.verifiable_producer import
VerifiableProducer
from kafkatest.services.zookeeper import ZookeeperService
from kafkatest.tests.produce_consume_validate import ProduceConsumeValidateTest
from kafkatest.utils import is_int
-from kafkatest.version import LATEST_0_9, LATEST_0_8_2, TRUNK, KafkaVersion
+from kafkatest.version import LATEST_0_10_0, LATEST_0_9, LATEST_0_8_2, TRUNK,
KafkaVersion
# Compatibility tests for moving to a new broker (e.g., 0.10.x) and using a
mix of old and new clients (e.g., 0.9.x)
@@ -50,6 +50,7 @@ class
ClientCompatibilityTestNewBroker(ProduceConsumeValidateTest):
@parametrize(producer_version=str(LATEST_0_9),
consumer_version=str(TRUNK), compression_types=["snappy"], new_consumer=True,
timestamp_type=None)
@parametrize(producer_version=str(TRUNK),
consumer_version=str(LATEST_0_9), compression_types=["snappy"],
new_consumer=True, timestamp_type=str("CreateTime"))
@parametrize(producer_version=str(TRUNK), consumer_version=str(TRUNK),
compression_types=["snappy"], new_consumer=True,
timestamp_type=str("LogAppendTime"))
+@parametrize(producer_version=str(LATEST_0_10_0),
consumer_version=str(LATEST_0_10_0), compression_types=["snappy"],
new_consumer=True, timestamp_type=str("LogAppendTime"))
@parametrize(producer_version=str(LATEST_0_9),
consumer_version=str(LATEST_0_9), compression_types=["snappy"],
new_consumer=True, timestamp_type=str("LogAppendTime"))
@parametrize(producer_version=str(TRUNK), consumer_version=str(TRUNK),
compression_types=["none"], timestamp_type=str("LogAppendTime"))
def test_compatibility(self, producer_version, consumer_version,
compression_types, new_consumer=False, timestamp_type=None):
http://git-wip-us.apache.org/repos/asf/kafka/blob/017defcd/tests/kafkatest/tests/core/upgrade_test.py
--
diff --git a/tests/kafkatest/tests/core/upgrade_test.py
b/tests/kafkatest/tests/core/upgrade_test.py
index 9c83991..062f3e5 100644
--- a/tests/kafkatest/tests/core/upgrade_test.py
+++ b/tests/kafkatest/tests/core/upgrade_test.py
@@ -24,8 +24,7 @@ from kafkatest.services.verifiable_producer import
VerifiableProducer
from kafkatest.services.zookeeper import ZookeeperService
from kafkatest.tests.produce_consume_validate import ProduceConsumeValidateTest
from kafkatest.utils import is_int
-from kafkatest.version import LATEST_0_8_2, LATEST_0_9, LATEST_0_10,
LATEST_0_10_0, TRUNK, KafkaVersion
-
+from kafkatest.version import LATEST_0_8_2, LATEST_0_9, LATEST_0_10_0, TRUNK,
KafkaVersion
class TestUpgrade(ProduceConsumeValidateTest):
@@ -61,8 +60,8 @@ class TestUpgrade(ProduceConsumeValidateTest):
node.config[config_property.MESSAGE_FORMAT_VERSION] =
to_message_format_version
self.kafka.start_node(node)
-
-@parametrize(from_kafka_version=str(LATEST_0_10_0),
to_message_format_version=None, compression_types=["none"])
+@parametrize(from_kafka_version=str(LATEST_0_10_0),
to_message_format_version=None, compression_types=["snappy"])
+@parametrize(from_kafka_version=str(LATEST_0_10_0),
to_message_format_version=None, compression_types=["snappy"], new_consumer=True)
@parametrize(from_kafka_version=str(LATEST_0_9),
to_me
kafka git commit: KAFKA-4165; Add 0.10.0.1 as a source for compatibility tests
Repository: kafka
Updated Branches:
refs/heads/0.10.1 41b12a6ad -> 017defcd1
KAFKA-4165; Add 0.10.0.1 as a source for compatibility tests
Author: Jason Gustafson
Reviewers: Ismael Juma
Closes #1959 from hachikuji/KAFKA-4165
(cherry picked from commit b3eef7bc72743b006d068ae6c3edf71d413ef433)
Signed-off-by: Jason Gustafson
Project: http://git-wip-us.apache.org/repos/asf/kafka/repo
Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/017defcd
Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/017defcd
Diff: http://git-wip-us.apache.org/repos/asf/kafka/diff/017defcd
Branch: refs/heads/0.10.1
Commit: 017defcd13061c5c8c4b55696b31e105da3cc27a
Parents: 41b12a6
Author: Jason Gustafson
Authored: Tue Oct 4 11:12:56 2016 -0700
Committer: Jason Gustafson
Committed: Tue Oct 4 11:13:07 2016 -0700
--
.../tests/core/compatibility_test_new_broker_test.py | 3 ++-
tests/kafkatest/tests/core/upgrade_test.py| 7 +++
2 files changed, 5 insertions(+), 5 deletions(-)
--
http://git-wip-us.apache.org/repos/asf/kafka/blob/017defcd/tests/kafkatest/tests/core/compatibility_test_new_broker_test.py
--
diff --git a/tests/kafkatest/tests/core/compatibility_test_new_broker_test.py
b/tests/kafkatest/tests/core/compatibility_test_new_broker_test.py
index 85fc9ae..7fe875d 100644
--- a/tests/kafkatest/tests/core/compatibility_test_new_broker_test.py
+++ b/tests/kafkatest/tests/core/compatibility_test_new_broker_test.py
@@ -22,7 +22,7 @@ from kafkatest.services.verifiable_producer import
VerifiableProducer
from kafkatest.services.zookeeper import ZookeeperService
from kafkatest.tests.produce_consume_validate import ProduceConsumeValidateTest
from kafkatest.utils import is_int
-from kafkatest.version import LATEST_0_9, LATEST_0_8_2, TRUNK, KafkaVersion
+from kafkatest.version import LATEST_0_10_0, LATEST_0_9, LATEST_0_8_2, TRUNK,
KafkaVersion
# Compatibility tests for moving to a new broker (e.g., 0.10.x) and using a
mix of old and new clients (e.g., 0.9.x)
@@ -50,6 +50,7 @@ class
ClientCompatibilityTestNewBroker(ProduceConsumeValidateTest):
@parametrize(producer_version=str(LATEST_0_9),
consumer_version=str(TRUNK), compression_types=["snappy"], new_consumer=True,
timestamp_type=None)
@parametrize(producer_version=str(TRUNK),
consumer_version=str(LATEST_0_9), compression_types=["snappy"],
new_consumer=True, timestamp_type=str("CreateTime"))
@parametrize(producer_version=str(TRUNK), consumer_version=str(TRUNK),
compression_types=["snappy"], new_consumer=True,
timestamp_type=str("LogAppendTime"))
+@parametrize(producer_version=str(LATEST_0_10_0),
consumer_version=str(LATEST_0_10_0), compression_types=["snappy"],
new_consumer=True, timestamp_type=str("LogAppendTime"))
@parametrize(producer_version=str(LATEST_0_9),
consumer_version=str(LATEST_0_9), compression_types=["snappy"],
new_consumer=True, timestamp_type=str("LogAppendTime"))
@parametrize(producer_version=str(TRUNK), consumer_version=str(TRUNK),
compression_types=["none"], timestamp_type=str("LogAppendTime"))
def test_compatibility(self, producer_version, consumer_version,
compression_types, new_consumer=False, timestamp_type=None):
http://git-wip-us.apache.org/repos/asf/kafka/blob/017defcd/tests/kafkatest/tests/core/upgrade_test.py
--
diff --git a/tests/kafkatest/tests/core/upgrade_test.py
b/tests/kafkatest/tests/core/upgrade_test.py
index 9c83991..062f3e5 100644
--- a/tests/kafkatest/tests/core/upgrade_test.py
+++ b/tests/kafkatest/tests/core/upgrade_test.py
@@ -24,8 +24,7 @@ from kafkatest.services.verifiable_producer import
VerifiableProducer
from kafkatest.services.zookeeper import ZookeeperService
from kafkatest.tests.produce_consume_validate import ProduceConsumeValidateTest
from kafkatest.utils import is_int
-from kafkatest.version import LATEST_0_8_2, LATEST_0_9, LATEST_0_10,
LATEST_0_10_0, TRUNK, KafkaVersion
-
+from kafkatest.version import LATEST_0_8_2, LATEST_0_9, LATEST_0_10_0, TRUNK,
KafkaVersion
class TestUpgrade(ProduceConsumeValidateTest):
@@ -61,8 +60,8 @@ class TestUpgrade(ProduceConsumeValidateTest):
node.config[config_property.MESSAGE_FORMAT_VERSION] =
to_message_format_version
self.kafka.start_node(node)
-
-@parametrize(from_kafka_version=str(LATEST_0_10_0),
to_message_format_version=None, compression_types=["none"])
+@parametrize(from_kafka_version=str(LATEST_0_10_0),
to_message_format_version=None, compression_types=["snappy"])
+@parametrize(from_kafka_version=str(LATEST_0_10_0),
to_message_format_version=None, compression_types=["snappy"], new_consumer=True)
@parametrize(from_kafka_version=str(LATEST_0_9),
to_me
kafka git commit: KAFKA-4165; Add 0.10.0.1 as a source for compatibility tests
Repository: kafka
Updated Branches:
refs/heads/trunk d8d2f3aac -> b3eef7bc7
KAFKA-4165; Add 0.10.0.1 as a source for compatibility tests
Author: Jason Gustafson
Reviewers: Ismael Juma
Closes #1959 from hachikuji/KAFKA-4165
Project: http://git-wip-us.apache.org/repos/asf/kafka/repo
Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/b3eef7bc
Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/b3eef7bc
Diff: http://git-wip-us.apache.org/repos/asf/kafka/diff/b3eef7bc
Branch: refs/heads/trunk
Commit: b3eef7bc72743b006d068ae6c3edf71d413ef433
Parents: d8d2f3a
Author: Jason Gustafson
Authored: Tue Oct 4 11:12:56 2016 -0700
Committer: Jason Gustafson
Committed: Tue Oct 4 11:12:56 2016 -0700
--
.../tests/core/compatibility_test_new_broker_test.py | 3 ++-
tests/kafkatest/tests/core/upgrade_test.py| 7 +++
2 files changed, 5 insertions(+), 5 deletions(-)
--
http://git-wip-us.apache.org/repos/asf/kafka/blob/b3eef7bc/tests/kafkatest/tests/core/compatibility_test_new_broker_test.py
--
diff --git a/tests/kafkatest/tests/core/compatibility_test_new_broker_test.py
b/tests/kafkatest/tests/core/compatibility_test_new_broker_test.py
index 85fc9ae..7fe875d 100644
--- a/tests/kafkatest/tests/core/compatibility_test_new_broker_test.py
+++ b/tests/kafkatest/tests/core/compatibility_test_new_broker_test.py
@@ -22,7 +22,7 @@ from kafkatest.services.verifiable_producer import
VerifiableProducer
from kafkatest.services.zookeeper import ZookeeperService
from kafkatest.tests.produce_consume_validate import ProduceConsumeValidateTest
from kafkatest.utils import is_int
-from kafkatest.version import LATEST_0_9, LATEST_0_8_2, TRUNK, KafkaVersion
+from kafkatest.version import LATEST_0_10_0, LATEST_0_9, LATEST_0_8_2, TRUNK,
KafkaVersion
# Compatibility tests for moving to a new broker (e.g., 0.10.x) and using a
mix of old and new clients (e.g., 0.9.x)
@@ -50,6 +50,7 @@ class
ClientCompatibilityTestNewBroker(ProduceConsumeValidateTest):
@parametrize(producer_version=str(LATEST_0_9),
consumer_version=str(TRUNK), compression_types=["snappy"], new_consumer=True,
timestamp_type=None)
@parametrize(producer_version=str(TRUNK),
consumer_version=str(LATEST_0_9), compression_types=["snappy"],
new_consumer=True, timestamp_type=str("CreateTime"))
@parametrize(producer_version=str(TRUNK), consumer_version=str(TRUNK),
compression_types=["snappy"], new_consumer=True,
timestamp_type=str("LogAppendTime"))
+@parametrize(producer_version=str(LATEST_0_10_0),
consumer_version=str(LATEST_0_10_0), compression_types=["snappy"],
new_consumer=True, timestamp_type=str("LogAppendTime"))
@parametrize(producer_version=str(LATEST_0_9),
consumer_version=str(LATEST_0_9), compression_types=["snappy"],
new_consumer=True, timestamp_type=str("LogAppendTime"))
@parametrize(producer_version=str(TRUNK), consumer_version=str(TRUNK),
compression_types=["none"], timestamp_type=str("LogAppendTime"))
def test_compatibility(self, producer_version, consumer_version,
compression_types, new_consumer=False, timestamp_type=None):
http://git-wip-us.apache.org/repos/asf/kafka/blob/b3eef7bc/tests/kafkatest/tests/core/upgrade_test.py
--
diff --git a/tests/kafkatest/tests/core/upgrade_test.py
b/tests/kafkatest/tests/core/upgrade_test.py
index 9c83991..062f3e5 100644
--- a/tests/kafkatest/tests/core/upgrade_test.py
+++ b/tests/kafkatest/tests/core/upgrade_test.py
@@ -24,8 +24,7 @@ from kafkatest.services.verifiable_producer import
VerifiableProducer
from kafkatest.services.zookeeper import ZookeeperService
from kafkatest.tests.produce_consume_validate import ProduceConsumeValidateTest
from kafkatest.utils import is_int
-from kafkatest.version import LATEST_0_8_2, LATEST_0_9, LATEST_0_10,
LATEST_0_10_0, TRUNK, KafkaVersion
-
+from kafkatest.version import LATEST_0_8_2, LATEST_0_9, LATEST_0_10_0, TRUNK,
KafkaVersion
class TestUpgrade(ProduceConsumeValidateTest):
@@ -61,8 +60,8 @@ class TestUpgrade(ProduceConsumeValidateTest):
node.config[config_property.MESSAGE_FORMAT_VERSION] =
to_message_format_version
self.kafka.start_node(node)
-
-@parametrize(from_kafka_version=str(LATEST_0_10_0),
to_message_format_version=None, compression_types=["none"])
+@parametrize(from_kafka_version=str(LATEST_0_10_0),
to_message_format_version=None, compression_types=["snappy"])
+@parametrize(from_kafka_version=str(LATEST_0_10_0),
to_message_format_version=None, compression_types=["snappy"], new_consumer=True)
@parametrize(from_kafka_version=str(LATEST_0_9),
to_message_format_version=None, compression_types=["none"])
@parametrize(from_kafka_version=str(LATEST_0
