Skip to content

Instantly share code, notes, and snippets.

@merlin-quix

merlin-quix/gzip_kafka_create_producer_2.py

Created January 22, 2023 14:41
Show Gist options
  • Star 0 You must be signed in to star a gist
  • Fork 0 You must be signed in to fork a gist
  • Save merlin-quix/eea21e45d5d6e4d5f2f24bec661402ae to your computer and use it in GitHub Desktop.
Save merlin-quix/eea21e45d5d6e4d5f2f24bec661402ae to your computer and use it in GitHub Desktop.
Download ZIP
Raw
gzip_kafka_create_producer_2.py
producer = KafkaProducer(bootstrap_servers=['localhost:9092'],
value_serializer=lambda x:json.dumps(x,default=str).encode('utf-8'),
key_serializer=lambda y:str(y).encode("utf-8"))
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment