Skip to content

[SPARK-12177] [STREAMING] Update KafkaDStreams to new Kafka 0.9 Consu…#10294

Closed
nikit-os wants to merge 16 commits into
apache:branch-1.6from
nikit-os:kafka-09-consumer-api
Closed

[SPARK-12177] [STREAMING] Update KafkaDStreams to new Kafka 0.9 Consu…#10294
nikit-os wants to merge 16 commits into
apache:branch-1.6from
nikit-os:kafka-09-consumer-api

implement consumer.poll(x) correctly based on https://issues.apache.o…

0fcda28
Select commit
Loading
Failed to load commit list.

Workflow runs completed with no jobs