1 files changed, 15 insertions, 0 deletions
diff --git a/data_generator.py b/data_generator.py
new file mode 100644
index 0000000..7b787cc
--- /dev/null
+++ b/data_generator.py
@@ -0,0 +1,15 @@
+"""Generate Fake data for kafka."""
+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)