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
>

Reply via email to