Spark SQL DataFrame to Kafka Topic

[Senthil Kumar]

Hi Team ,

     Sorry if this question already asked in this forum..

Can we ingest data to Apache Kafka Topic from Spark SQL DataFrame ??

Here is my Code which Reads Parquet File :

*val sqlContext = new org.apache.spark.sql.SQLContext(sc);*

*val df = sqlContext.read.parquet("..../temp/*.parquet")*

*df.registerTempTable("beacons")*


I want to directly ingest df DataFrame to Kafka ! Is there any way to
achieve this ??


Cheers,

Senthil