From f2e4da7e296548fb3980fd212e3a67dc83254e1d Mon Sep 17 00:00:00 2001 From: rameshiyer27 Date: Sat, 13 Jan 2024 21:26:09 +0000 Subject: Add kafka support in Policy CSIT Issue-ID: POLICY-4402 Signed-off-by: zrrmmua Change-Id: I802c19a3c9817d304164eba634adb8c119aa4ced --- csit/resources/tests/common-library.robot | 6 +++--- 1 file changed, 3 insertions(+), 3 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 f5db8e0e..531572d2 100644 --- a/csit/resources/tests/common-library.robot +++ b/csit/resources/tests/common-library.robot @@ -150,9 +150,9 @@ CheckTopic 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} + ${resp}= Run Process ${CURDIR}/kafka_consumer.py ${topic} 60 ${expected_status} + Should Contain ${resp.stdout} ${expected_status} + [Return] ${resp.stdout} GetKafkaTopic [Arguments] ${topic} -- cgit 1.2.3-korg