[ https://issues.apache.org/jira/browse/SPARK-2492?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Tathagata Das updated SPARK-2492: --------------------------------- Target Version/s: 1.1.0 Fix Version/s: (was: 1.1.0) > KafkaReceiver minor changes to align with Kafka 0.8 > ---------------------------------------------------- > > Key: SPARK-2492 > URL: https://issues.apache.org/jira/browse/SPARK-2492 > Project: Spark > Issue Type: Improvement > Components: Streaming > Affects Versions: 1.0.0 > Reporter: Saisai Shao > Assignee: Saisai Shao > Priority: Minor > > Update to delete Zookeeper metadata when Kafka's parameter > "auto.offset.reset" is set to "smallest", which is aligned with Kafka 0.8's > ConsoleConsumer. > Also use Kafka offered API without directly using zkClient. -- This message was sent by Atlassian JIRA (v6.2#6252)