----------------------------------------------------------- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/30809/ -----------------------------------------------------------
(Updated Feb. 9, 2015, 11:53 p.m.) Review request for kafka. Bugs: KAFKA-1888 https://issues.apache.org/jira/browse/KAFKA-1888 Repository: kafka Description (updated) ------- Essentially this test does the following: a) Start a java process with 3 threads Producer - producing continuously Consumer - consuming from latest Bootstrap consumer - started after a pause to bootstrap from beginning. It uses sequentially increasing numbers and timestamps to make sure we are not receiving out of order messages and do real-time validation. b) Script which wraps this and takes two directories which contain the kafka version specific jars: kafka_2.10-0.8.3-SNAPSHOT-test.jar kafka_2.10-0.8.3-SNAPSHOT.jar The first argument is the directory containing the older version of the jars. The second argument is the directory containing the newer version of the jars. The reason for choosing directories was because there are two jars in these directories: Diffs ----- build.gradle c3e6bb839ad65c512c9db4695d2bb49b82c80da5 core/src/main/scala/kafka/tools/ContinuousValidationTest.java PRE-CREATION system_test/broker_upgrade/bin/kafka-run-class.sh PRE-CREATION system_test/broker_upgrade/bin/test.sh PRE-CREATION system_test/broker_upgrade/configs/server1.properties PRE-CREATION system_test/broker_upgrade/configs/server2.properties PRE-CREATION system_test/broker_upgrade/configs/zookeeper_source.properties PRE-CREATION Diff: https://reviews.apache.org/r/30809/diff/ Testing (updated) ------- Scripted it to run 20 times without any failures. Command-line: broker-upgrade/bin/test.sh <dir1> <dir2> Thanks, Abhishek Nigam