gojek/ziggurat

how to set offset comit to earliest

salismt opened this issue · 1 comments

Can you show me the config for setting offset commit to earliest?

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"}}