Re: Spark Streaming Kafka - DirectKafkaInputDStream: Using the new Kafka Consumer API

2015-12-04 Thread Mario Ds Briggs
>> forcing people on kafka 8.x to upgrade their brokers is questionable. << I agree and i was more thinking maybe there is a way to support both for a period of time (of course means some more code to maintain :-)). thanks Mario From: Cody Koeninger To: Mario Ds

Re: Quick question regarding Maven and Spark Assembly jar

2015-12-04 Thread Sean Owen
I think one problem is that the assembly by nature includes a bunch of particular versions of dependencies. Only one can be published, but, it would be unlikely to be the right flavor of assembly for any given user. On Fri, Dec 4, 2015 at 1:27 AM, Matt Cheah wrote: > Hi

Re: A proposal for Spark 2.0

2015-12-04 Thread Sean Owen
To be clear-er, I don't think it's clear yet whether a 1.7 release should exist or not. I could see both making sense. It's also not really necessary to decide now, well before a 1.6 is even out in the field. Deleting the version lost information, and I would not have done that given my reply.

Re: Spark Streaming Kafka - DirectKafkaInputDStream: Using the new Kafka Consumer API

2015-12-04 Thread Cody Koeninger
Brute force way to do it might be to just have a separate streaming-kafka-new-consumer subproject, or something along those lines. On Fri, Dec 4, 2015 at 3:12 AM, Mario Ds Briggs wrote: > >> > forcing people on kafka 8.x to upgrade their brokers is questionable. > << >