summaryrefslogtreecommitdiffstats
path: root/csit/resources/tests/kafka_producer.py
diff options
context:
space:
mode:
authoradheli.tavares <adheli.tavares@est.tech>2024-09-26 14:16:09 +0100
committeradheli.tavares <adheli.tavares@est.tech>2024-09-27 09:36:18 +0100
commita3d2dc6ac57903b4fd970043732159a59f1cb2ae (patch)
tree91d07d6a0c02e587df94159531f31ce5582ec4fa /csit/resources/tests/kafka_producer.py
parentc4497b791b8d60137a07d0639437e78d9e158bf0 (diff)
Add extra test cases for drools-pdp
- fix some references on robot files - drools policy execution not completing because of issues with AppcLcm simulator - uncommenting the executions - dcae_topic having topic name and effective topic now are the same Issue-ID: POLICY-4955 Change-Id: Ia45730c6ba2b473acfc5b317424a0a46b3660485 Signed-off-by: adheli.tavares <adheli.tavares@est.tech>
Diffstat (limited to 'csit/resources/tests/kafka_producer.py')
-rwxr-xr-xcsit/resources/tests/kafka_producer.py2
1 files changed, 2 insertions, 0 deletions
diff --git a/csit/resources/tests/kafka_producer.py b/csit/resources/tests/kafka_producer.py
index a7d45647..e960b934 100755
--- a/csit/resources/tests/kafka_producer.py
+++ b/csit/resources/tests/kafka_producer.py
@@ -24,6 +24,7 @@
from confluent_kafka import Producer
import sys
+
def post_to_kafka(topic, message, bootstrap_server):
conf = {'bootstrap.servers': bootstrap_server}
@@ -37,5 +38,6 @@ def post_to_kafka(topic, message, bootstrap_server):
finally:
producer.flush()
+
if __name__ == '__main__':
post_to_kafka(sys.argv[1], sys.argv[2], sys.argv[3])