From f2609a349565f74237024f2f546e03ea5c772cb5 Mon Sep 17 00:00:00 2001
From: rameshiyer27 <ramesh.murugan.iyer@est.tech>
Date: Thu, 14 Dec 2023 14:17:35 +0000
Subject: 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
---
 csit/resources/tests/common-library.robot | 10 ++++++++++
 1 file changed, 10 insertions(+)

(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 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
-- 
cgit