kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From jun...@apache.org
Subject 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
Date Fri, 11 Apr 2014 21:39:40 GMT
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 <guwang@linkedin.com>
Authored: Fri Apr 11 14:39:35 2014 -0700
Committer: Jun Rao <junrao@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)
 


Mime
View raw message