You are viewing a plain text version of this content. The canonical link for it is here.
Posted to user@spark.apache.org by Prabhu GS <pr...@thedatateam.in> on 2016/10/25 09:30:23 UTC

Spark streaming communication with different versions of kafka

Hi,

I would like to know if the same spark streaming job can consume from kafka
0.8.1 and write the data to kafka 0.9. Just trying to replicate the kafka
server.

Yes, Kafka's MirrorMaker can be used to replicate, but was curious to know
if that can be achieved by spark streaming.

Please share your thoughts

-- 
Prabhu

Re: Spark streaming communication with different versions of kafka

Posted by Cody Koeninger <co...@koeninger.org>.
Kafka consumers should be backwards compatible with kafka brokers, so
at the very least you should be able to use the
streaming-spark-kafka-0-10 to do what you're talking about.

On Tue, Oct 25, 2016 at 4:30 AM, Prabhu GS <pr...@thedatateam.in> wrote:
> Hi,
>
> I would like to know if the same spark streaming job can consume from kafka
> 0.8.1 and write the data to kafka 0.9. Just trying to replicate the kafka
> server.
>
> Yes, Kafka's MirrorMaker can be used to replicate, but was curious to know
> if that can be achieved by spark streaming.
>
> Please share your thoughts
>
> --
> Prabhu
>

---------------------------------------------------------------------
To unsubscribe e-mail: user-unsubscribe@spark.apache.org


Spark streaming communication with InfluxDB

Posted by Gioacchino <gi...@gmail.com>.
Hi,


I wouild like to know if there is code example to write data in InfluxDB 
from Spark Streaming in Scala / Python.


Thanks in advance

Gioacchino


---------------------------------------------------------------------
To unsubscribe e-mail: user-unsubscribe@spark.apache.org