Skip to content
This repository has been archived by the owner on Dec 20, 2018. It is now read-only.

Consume Avro stream from Kafka topic #232

Open
ananth3010 opened this issue Jun 8, 2017 · 3 comments
Open

Consume Avro stream from Kafka topic #232

ananth3010 opened this issue Jun 8, 2017 · 3 comments

Comments

@ananth3010
Copy link

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
Copy link
Author

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

@ananth3010
Copy link
Author

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

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

@ananth3010 ananth3010 reopened this Jun 8, 2017
@OneCricketeer
Copy link

Sign up for free to subscribe to this conversation on GitHub. Already have an account? Sign in.
Labels
None yet
Projects
None yet
Development

No branches or pull requests

2 participants