how to set offset comit to earliest
salismt opened this issue · 1 comments
salismt commented
Can you show me the config for setting offset commit to earliest?
theanirudhvyas commented
Hey @salismt , there is a configuration to set the offset to earliest - auto-offset-reset-config
. This config is nested inside your stream-route configuration in config.edn
:stream-router {:topic-entity {:application-id "application-id"
:bootstrap-servers "kafka-servers"
:stream-threads-count [1 :int]
:origin-topic "topic-regex"
:auto-offset-reset-config "earliest"}}