Skip to content Skip to sidebar Skip to footer
Showing posts with the label Kafka Python

How To Properly Use Pyspark To Send Data To Kafka Broker?

I'm trying to write a simple pyspark job, which would receive data from a kafka broker topic, d… Read more How To Properly Use Pyspark To Send Data To Kafka Broker?

Kafka-python Read From Last Produced Message After A Consumer Restart

i am using kafka-python to consume messages from a kafka queue (kafka version 0.10.2.0). In particu… Read more Kafka-python Read From Last Produced Message After A Consumer Restart