You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
add spring.cloud.stream.kafka.bindings.songInput.consumer.startOffset: latest and spring.cloud.stream.kafka.bindings.songInput.consumer.resetOffset: false to appconfig so it behaves this way by default
Currently if the consumer group is deleted maestro will recreate the group and start consuming messages from the earliest available offset
Detailed Description
Possible Implementation
In spring if we set resetOffset to
false
and startOffset tolatest
on a binding it will consume from the latest offset if the consumer group is new or it will consume from the last committed offset if the consumer group existsmroe info: https://docs.spring.io/spring-cloud-stream-binder-kafka/docs/3.1.4/reference/html/spring-cloud-stream-binder-kafka.html#reset-offsets
add
spring.cloud.stream.kafka.bindings.songInput.consumer.startOffset: latest
andspring.cloud.stream.kafka.bindings.songInput.consumer.resetOffset: false
to appconfig so it behaves this way by defaulthere:
maestro/maestro-app/src/main/resources/config/application.yml
Line 150 in 7f3388a
The text was updated successfully, but these errors were encountered: