Skip to content

Instantly share code, notes, and snippets.

@dvainrub
Last active June 6, 2019 10:52
Show Gist options
  • Save dvainrub/bd31433d1e2d2ee51433d318221719e0 to your computer and use it in GitHub Desktop.
Save dvainrub/bd31433d1e2d2ee51433d318221719e0 to your computer and use it in GitHub Desktop.
from kafka import KafkaProducer
from json import dumps
producer = KafkaProducer(
value_serializer=lambda m: dumps(m).encode('utf-8'),
bootstrap_servers=['172.17.0.1:32783','172.17.0.1:32782','172.17.0.1:32781'])
producer.send("test", value={"hello": "producer"})
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment