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. On Wed, Aug 9, 2017 at 9:25 AM, Manoj Murumkar <manoj.murum...@gmail.com> wrote: > 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 of type > io.confluent.connect.hdfs > .HdfsSinkTask (org.apache.kafka.connect.runtime.Worker:317) > [2017-08-09 15:34:24,748] INFO ConsumerConfig values: > auto.commit.interval.ms = 5000 > auto.offset.reset = earliest > > Can someone tell me where this might be getting set? > > Thanks, > > Manoj >
