diff options
author | adheli.tavares <adheli.tavares@est.tech> | 2024-09-26 14:16:09 +0100 |
---|---|---|
committer | adheli.tavares <adheli.tavares@est.tech> | 2024-09-27 09:36:18 +0100 |
commit | a3d2dc6ac57903b4fd970043732159a59f1cb2ae (patch) | |
tree | 91d07d6a0c02e587df94159531f31ce5582ec4fa /csit/resources/tests/kafka_producer.py | |
parent | c4497b791b8d60137a07d0639437e78d9e158bf0 (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-x | csit/resources/tests/kafka_producer.py | 2 |
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]) |