Re: auto.offset.reset defaulting to earliest

2017-08-09 Thread Manoj Murumkar
In fact, bunch of parameters are not taking effect, no matter what I set it in config: auto.commit.interval.ms = 5000 enable.auto.commit = false Is it because the connector is setting consumer configs to default somewhere in the code and ignoring values in config file? Any help is appreciated.

auto.offset.reset defaulting to earliest

2017-08-09 Thread Manoj Murumkar
Hi, I am running standalone connector and explicitly setting auto.offset.reset parameter to latest in the properties file (which is default value). However, when I look at the logs, here's what I see: 2017-08-09 15:34:24,731] INFO Instantiated task hdfs-sink-cdpos_cdhdr_view-0 with version 3.2.0