diff options
| author |   rameshiyer27 <ramesh.murugan.iyer@est.tech> | 2023-12-14 14:17:35 +0000 |
|---|---|---|
| committer | rameshiyer27 <ramesh.murugan.iyer@est.tech> | 2023-12-14 14:17:35 +0000 |
| commit | f2609a349565f74237024f2f546e03ea5c772cb5 (patch) | |
| tree | acdd9010ce27231dae1e42aed03472d173855799 /csit/resources/tests | |
| parent | dae767c98f1f15da96d543f029c846d95a5de76a (diff) | |
Add kafka docker container for policy CSITs
Replaced dmaap with kafka in CLAMP docker tests.
Issue-ID: POLICY-4201
Signed-off-by: zrrmmua <ramesh.murugan.iyer@est.tech>
Change-Id: I4d05e24d3ececf2253ebc39785882be00bf9eaf4
Diffstat (limited to 'csit/resources/tests')
| -rw-r--r-- | csit/resources/tests/common-library.robot | 10 |
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 |