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/04/11 23:39:40 UTC
git commit: kafka-1337;
follow-up patch to add broker list for new producer in system test
overriden function; patched by Guozhang Wang;
reviewed by Neha Narkhede, Jun Rao
Repository: kafka
Updated Branches:
refs/heads/trunk 44ee6b7c9 -> 2d429e19d
kafka-1337; follow-up patch to add broker list for new producer in system test overriden function; 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/2d429e19
Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/2d429e19
Diff: http://git-wip-us.apache.org/repos/asf/kafka/diff/2d429e19
Branch: refs/heads/trunk
Commit: 2d429e19da22416aeb7de68b9e00f33a337e31a0
Parents: 44ee6b7
Author: Guozhang Wang <gu...@linkedin.com>
Authored: Fri Apr 11 14:39:35 2014 -0700
Committer: Jun Rao <ju...@gmail.com>
Committed: Fri Apr 11 14:39:35 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/2d429e19/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 3ab758a..423b512 100644
--- a/system_test/utils/kafka_system_test_utils.py
+++ b/system_test/utils/kafka_system_test_utils.py
@@ -458,6 +458,7 @@ def generate_overriden_props_files(testsuitePathname, testcaseEnv, systemTestEnv
elif ( clusterCfg["role"] == "mirror_maker"):
tcCfg["metadata.broker.list"] = testcaseEnv.userDefinedEnvVarDict["targetBrokerList"]
+ tcCfg["bootstrap.servers"] = testcaseEnv.userDefinedEnvVarDict["targetBrokerList"] # for new producer
copy_file_with_dict_values(cfgTemplatePathname + "/mirror_producer.properties",
cfgDestPathname + "/" + tcCfg["mirror_producer_config_filename"], tcCfg, None)