diff options
author | rameshiyer27 <ramesh.murugan.iyer@est.tech> | 2023-12-14 14:17:35 +0000 |
---|---|---|
committer | rameshiyer27 <ramesh.murugan.iyer@est.tech> | 2023-12-14 14:17:35 +0000 |
commit | f2609a349565f74237024f2f546e03ea5c772cb5 (patch) | |
tree | acdd9010ce27231dae1e42aed03472d173855799 /csit/resources/scripts/kafka_producer.py | |
parent | dae767c98f1f15da96d543f029c846d95a5de76a (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-x | csit/resources/scripts/kafka_producer.py | 41 |
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]) |