its set to none for the executors, because otherwise they wont do exactly what the driver told them to do.
you should be able to set up the driver consumer to determine batches however you want, though. On Wednesday, October 12, 2016, Haopu Wang <hw...@qilinsoft.com> wrote: > Hi, > > > > I want to read the existing Kafka messages and then subscribe new stream > messages. > > But I find "auto.offset.reset" property is always set to "none" in > KafkaUtils. Does that mean I cannot specify "earliest" property value when > create direct stream? > > Thank you! > > >
