There is an example in this post: https://databricks.com/blog/2017/04/04/real-time-end-to-end-integration-with-apache-kafka-in-apache-sparks-structured-streaming.html
On Tue, May 23, 2017 at 11:35 AM, kant kodali <kanth...@gmail.com> wrote: > Hi All, > > Are there any Kafka forEachSink examples preferably in Java but Scala is > fine too? > > Thanks! >