blob: 7b787cc25e9ddb3b3dc62d9afb3fcb79acce2d40 (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
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)
|
