Producer and consumer overrides used by the connect worker can be overridden by prefixing the specific kafka config with either 'producer.' or 'consumer.'. So, you should be able to set 'consumer.auto.offset.reset=latest' in your worker config to do that.
http://docs.confluent.io/3.0.0/connect/userguide.html?highlight=override%20configuration#overriding-producer-consumer-settings On Tue, Mar 14, 2017 at 7:47 PM, Aaron Niskode-Dossett < aniskodedoss...@etsy.com.invalid> wrote: > Is it possible to start a kafka connect instance that reads from the > *latest* offset as opposed to the earliest? I suppose this would be the > equivalent of passing auto.offset.reset=earliest to a kafka consumer. > > More generally, is this something that specific implementations of the > kafka connect API would have to be responsible for handling or should it > exposed through the connect API? > > Thanks, Aaron >
