You are viewing a plain text version of this content. The canonical link for it is here.

Posted to user@spark.apache.org by kant kodali <ka...@gmail.com> on 2017/05/23 18:35:31 UTC

Are there any Kafka forEachSink examples?

Hi All,

Are there any Kafka forEachSink examples preferably in Java but Scala is
fine too?

Thanks!

Re: Are there any Kafka forEachSink examples?

Posted by kant kodali <ka...@gmail.com>.

Thanks a lot Michael! I am not sure why Google search doesn't take me to
databricks blog when I typed in relevant keywords on various things.
Perhaps the blog needs some metadata for the search engine to index or
 Google is more focused on Ads than relevant docs?!

On Tue, May 23, 2017 at 12:17 PM, Michael Armbrust <mi...@databricks.com>
wrote:

> 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 <ka...@gmail.com> wrote:
>
>> Hi All,
>>
>> Are there any Kafka forEachSink examples preferably in Java but Scala is
>> fine too?
>>
>> Thanks!
>>
>
>

Re: Are there any Kafka forEachSink examples?

Posted by Michael Armbrust <mi...@databricks.com>.

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 <ka...@gmail.com> wrote:

> Hi All,
>
> Are there any Kafka forEachSink examples preferably in Java but Scala is
> fine too?
>
> Thanks!
>