summaryrefslogtreecommitdiffstats
path: root/csit/resources/scripts/kafka_producer.py
diff options
context:
space:
mode:
authorrameshiyer27 <ramesh.murugan.iyer@est.tech>2023-12-14 14:17:35 +0000
committerrameshiyer27 <ramesh.murugan.iyer@est.tech>2023-12-14 14:17:35 +0000
commitf2609a349565f74237024f2f546e03ea5c772cb5 (patch)
treeacdd9010ce27231dae1e42aed03472d173855799 /csit/resources/scripts/kafka_producer.py
parentdae767c98f1f15da96d543f029c846d95a5de76a (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/scripts/kafka_producer.py')
-rwxr-xr-xcsit/resources/scripts/kafka_producer.py41
1 files changed, 41 insertions, 0 deletions
diff --git a/csit/resources/scripts/kafka_producer.py b/csit/resources/scripts/kafka_producer.py
new file mode 100755
index 00000000..ff129872
--- /dev/null
+++ b/csit/resources/scripts/kafka_producer.py
@@ -0,0 +1,41 @@
+#!/usr/bin/env python3
+#
+# ============LICENSE_START====================================================
+# Copyright (C) 2023 Nordix Foundation.
+# =============================================================================
+# Licensed under the Apache License, Version 2.0 (the "License");
+# you may not use this file except in compliance with the License.
+# You may obtain a copy of the License at
+#
+# http://www.apache.org/licenses/LICENSE-2.0
+#
+# Unless required by applicable law or agreed to in writing, software
+# distributed under the License is distributed on an "AS IS" BASIS,
+# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+# See the License for the specific language governing permissions and
+# limitations under the License.
+#
+# SPDX-License-Identifier: Apache-2.0
+# ============LICENSE_END======================================================
+
+# Python utility to produce a message on a kafka topic
+# Accepts the arguments {topic_name} and {message}
+
+from confluent_kafka import Producer
+import sys
+
+def post_to_kafka(topic, message):
+ conf = {'bootstrap.servers': 'localhost:29092'}
+
+ producer = Producer(conf)
+ try:
+ producer.produce(topic, value=message.encode('utf-8'))
+ producer.flush()
+ print('Message posted to Kafka topic: {}'.format(topic))
+ except Exception as e:
+ print('Failed to post message: {}'.format(str(e)))
+ finally:
+ producer.flush()
+
+if __name__ == '__main__':
+ post_to_kafka(sys.argv[1], sys.argv[2])