root
/
kafka
mirror of https://github.com/apache/kafka.git
1
0
Fork 0
Code Issues Actions 2 Packages Projects Releases Wiki Activity

kafka-1078; Update System Test to handle controller data returned by ZK; patched by John Fung; reviewed by Jun Rao

This commit is contained in:
John Fung 2013-10-08 09:22:32 -07:00 committed by Jun Rao
parent f53fe18361
commit a6904a2644
1 changed files with 10 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
system_test/utils/kafka_system_test_utils.py
View File

@ -1878,10 +1878,16 @@ def get_controller_attributes(systemTestEnv, testcaseEnv):
logger.debug("executing command [" + cmdStr + "]", extra=d) logger.debug("executing command [" + cmdStr + "]", extra=d)
subproc = system_test_utils.sys_call_return_subproc(cmdStr) subproc = system_test_utils.sys_call_return_subproc(cmdStr)
for line in subproc.stdout.readlines(): for line in subproc.stdout.readlines():
brokerid = line.rstrip('\n') if "brokerid" in line:
controllerDict["brokerid"] = brokerid json_str = line.rstrip('\n')
controllerDict["entity_id"] = system_test_utils.get_data_by_lookup_keyval( json_data = json.loads(json_str)
tcConfigsList, "broker.id", brokerid, "entity_id") brokerid = str(json_data["brokerid"])
controllerDict["brokerid"] = brokerid
controllerDict["entity_id"] = system_test_utils.get_data_by_lookup_keyval(
tcConfigsList, "broker.id", brokerid, "entity_id")
else:
pass
return controllerDict return controllerDict
def getMinCommonStartingOffset(systemTestEnv, testcaseEnv, clusterName="source"): def getMinCommonStartingOffset(systemTestEnv, testcaseEnv, clusterName="source"):