[SPARK-12177][Streaming][Kafka] Update KafkaDStreams to new Kafka 0.10 Consumer API#11863

Closed

koeninger wants to merge 42 commits intoapache:masterfrom

koeninger:kafka-0.9

Commits on Mar 3, 2016

[SPARK-12177][Streaming][Kafka] separate project for starting work on beta consumer, modify getPreferredLocations to choose a consistent executor per topicpartition
koeninger
committed

Commits on Mar 4, 2016

[SPARK-12177][Streaming][Kafka] WIP modify KafkaRDD to use cached new consumers
koeninger
committed

Commits on Mar 7, 2016

Commits on Mar 8, 2016

Commits on Mar 9, 2016

Commits on Mar 10, 2016

[SPARK-12177][Streaming][Kafka] WIP add java convenience constructors, fix tests
koeninger
committed

Commits on Mar 11, 2016

[SPARK-12177][Streaming][Kafka] WIP allow user configuration of consumer for dynamic topics, listener, etc
koeninger
committed

Commits on Mar 15, 2016

Commits on Mar 21, 2016

Commits on Apr 7, 2016

[SPARK-12177][Streaming][Kafka] workaround performance issues, error on attempts to serialize ConsumerRecord
koeninger
committed

Commits on Apr 8, 2016

Commits on Apr 18, 2016

[SPARK-12177][Streaming][Kafka] code review changes
koeninger
committed

Commits on May 6, 2016

Commits on May 27, 2016

Commits on Jun 14, 2016

[SPARK-12177][Streaming][Kafka] rename kafka-beta to kafka-0-10
koeninger
committed

Commits on Jun 28, 2016

[SPARK-12177][Streaming][Kafka] review feedback
koeninger
committed

Commits on Jun 29, 2016

Commits on Jun 30, 2016