Skip to content Skip to sidebar Skip to footer
Showing posts with the label Spark Streaming

Spark Stream - 'utf8' Codec Can't Decode Bytes

I'm fairly new to stream programming. We have Kafka stream which use Avro. I want to connect a … Read more Spark Stream - 'utf8' Codec Can't Decode Bytes

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?