spark-avro icon indicating copy to clipboard operation
spark-avro copied to clipboard

Consume Avro stream from Kafka topic

Open ananth3010 opened this issue 8 years ago • 3 comments

Hi

The current version reads .avro files from HDFS (or) any FS file path. I am storing my avro file stream in Kafka. Do you have a utility to read a avro stream (or) file from a Kafka topic?

If so could you let me know?

ananth3010 avatar Jun 08 '17 02:06 ananth3010

#216 has this resolved. Is there a documentation on how to use this?

ananth3010 avatar Jun 08 '17 02:06 ananth3010

#201 confirms this. Pasting it here for others benefit:

You can do this with DStream.foreachRDD { rdd => df = rddToDataFrame(rdd) }

ananth3010 avatar Jun 08 '17 06:06 ananth3010

This post shows Spark 2.4 Avro features and Kafka https://databricks.com/blog/2018/11/30/apache-avro-as-a-built-in-data-source-in-apache-spark-2-4.html

OneCricketeer avatar Dec 10 '18 22:12 OneCricketeer