From 31c61d495474985b8cc3460464f888651d0919ed Mon Sep 17 00:00:00 2001 From: rameshiyer27 Date: Sun, 21 Jan 2024 14:24:03 +0000 Subject: Add kafka support in K8s CSIT Issue-ID: POLICY-4402 Signed-off-by: zrrmmua Change-Id: I29ef966ed5eb70997574269ff6180f68d754383b --- csit/resources/tests/common-library.robot | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) (limited to 'csit/resources/tests/common-library.robot') diff --git a/csit/resources/tests/common-library.robot b/csit/resources/tests/common-library.robot index 8693be14..bc140897 100644 --- a/csit/resources/tests/common-library.robot +++ b/csit/resources/tests/common-library.robot @@ -133,10 +133,10 @@ ValidateResponseTime CheckKafkaTopic [Arguments] ${topic} ${expected_status} - ${resp}= Run Process ${CURDIR}/kafka_consumer.py ${topic} 60 ${expected_status} + ${resp}= Run Process ${CURDIR}/kafka_consumer.py ${topic} 60 ${expected_status} ${KAFKA_IP} Should Contain ${resp.stdout} ${expected_status} [Return] ${resp.stdout} GetKafkaTopic [Arguments] ${topic} - ${resp}= Run Process ${CURDIR}/make_topics.py ${topic} \ No newline at end of file + ${resp}= Run Process ${CURDIR}/make_topics.py ${topic} ${KAFKA_IP} \ No newline at end of file -- cgit