You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by ju...@apache.org on 2014/05/08 06:02:23 UTC
git commit: kafka-1432;
followup patch to enable new producer in system test; patched by Guozhang Wang;
reviewed by Neha Narkhede, Jun Rao
Repository: kafka
Updated Branches:
refs/heads/trunk 2848a7ab5 -> 754dacb90
kafka-1432; followup patch to enable new producer in system test; patched by Guozhang Wang; reviewed by Neha Narkhede, Jun Rao
Project: http://git-wip-us.apache.org/repos/asf/kafka/repo
Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/754dacb9
Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/754dacb9
Diff: http://git-wip-us.apache.org/repos/asf/kafka/diff/754dacb9
Branch: refs/heads/trunk
Commit: 754dacb90b48ee2cd226d544ab0c9cefa692f171
Parents: 2848a7a
Author: Guozhang Wang <gu...@linkedin.com>
Authored: Wed May 7 20:42:42 2014 -0700
Committer: Jun Rao <ju...@gmail.com>
Committed: Wed May 7 20:43:06 2014 -0700
----------------------------------------------------------------------
system_test/utils/kafka_system_test_utils.py | 1 +
1 file changed, 1 insertion(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/kafka/blob/754dacb9/system_test/utils/kafka_system_test_utils.py
----------------------------------------------------------------------
diff --git a/system_test/utils/kafka_system_test_utils.py b/system_test/utils/kafka_system_test_utils.py
index 6917ea1..de02e47 100644
--- a/system_test/utils/kafka_system_test_utils.py
+++ b/system_test/utils/kafka_system_test_utils.py
@@ -750,6 +750,7 @@ def start_entity_in_background(systemTestEnv, testcaseEnv, entityId):
kafkaHome + "/bin/kafka-run-class.sh kafka.tools.MirrorMaker",
"--consumer.config " + configPathName + "/" + mmConsumerConfigFile,
"--producer.config " + configPathName + "/" + mmProducerConfigFile,
+ "--new.producer",
"--whitelist=\".*\" >> ",
logPathName + "/" + logFile + " & echo pid:$! > ",
logPathName + "/entity_" + entityId + "_pid'"]