From a381884d323b67844d0ed7910b37171560a2d9d3 Mon Sep 17 00:00:00 2001 From: Starfall Date: Tue, 2 Jul 2024 17:26:40 -0500 Subject: kafka-send: new python script to produce kafka messages --- kafka-send/kafka-send.py | 16 ++++++++++++++++ 1 file changed, 16 insertions(+) create mode 100755 kafka-send/kafka-send.py (limited to 'kafka-send/kafka-send.py') diff --git a/kafka-send/kafka-send.py b/kafka-send/kafka-send.py new file mode 100755 index 0000000..b8ef414 --- /dev/null +++ b/kafka-send/kafka-send.py @@ -0,0 +1,16 @@ +#!/usr/bin/env python3 +import argparse +import kafka + +parser = argparse.ArgumentParser() +parser.add_argument('-s', '--server', default='localhost:9092', help='kafka bootstrap server (default localhost:9092)') +parser.add_argument('topic', help='kafka topic') +parser.add_argument('filename', help='file containing the message to be sent') +args = parser.parse_args() + +with open(args.filename, 'r') as file: + msg = ''.join(file.readlines()).encode() + +producer = kafka.KafkaProducer(bootstrap_servers=args.server) +producer.send(args.topic, msg) +producer.flush() -- cgit