From 3908bbe94637fee87bf250e2f2f210b3b2724c90 Mon Sep 17 00:00:00 2001
From: Cody Hiar <cody@hiar.ca>
Date: Fri, 8 Oct 2021 19:47:23 -0600
Subject: initial commit

---
 producer.py | 14 ++++++++++++++
 1 file changed, 14 insertions(+)
 create mode 100644 producer.py

(limited to 'producer.py')

diff --git a/producer.py b/producer.py
new file mode 100644
index 0000000..2acae44
--- /dev/null
+++ b/producer.py
@@ -0,0 +1,14 @@
+from time import sleep
+from json import dumps
+from kafka import KafkaProducer
+
+producer = KafkaProducer(
+    bootstrap_servers=['kafka:9092'],
+    value_serializer=lambda x: dumps(x).encode('utf-8')
+)
+
+for j in range(9999):
+    print("Iteration", j)
+    data = {'counter': j}
+    producer.send('topic_test', value=data)
+    sleep(0.5)
-- 
cgit v1.2.3