aboutsummaryrefslogtreecommitdiffstats
path: root/csit/resources/tests
diff options
context:
space:
mode:
Diffstat (limited to 'csit/resources/tests')
-rw-r--r--csit/resources/tests/common-library.robot10
1 files changed, 10 insertions, 0 deletions
diff --git a/csit/resources/tests/common-library.robot b/csit/resources/tests/common-library.robot
index 8c279176..f5db8e0e 100644
--- a/csit/resources/tests/common-library.robot
+++ b/csit/resources/tests/common-library.robot
@@ -147,3 +147,13 @@ CheckTopic
Status Should Be OK ${resp}
Should Contain ${resp.text} ${expected_status}
[Return] ${resp.text}
+
+CheckKafkaTopic
+ [Arguments] ${topic} ${expected_status}
+ ${resp}= Run Process ${CURDIR}/kafka_consumer.py ${topic} 30 ${expected_status}
+ Log to console Received response from kafka ${resp.stdout}
+ Should Contain ${resp.text} ${expected_status}
+
+GetKafkaTopic
+ [Arguments] ${topic}
+ ${resp}= Run Process ${CURDIR}/make_topics.py ${topic} \ No newline at end of file