在我的spring boot应用程序中使用spring cloud stream version brooklyn.sr1和spring cloud starter stream kafka。每次重新启动应用程序时,我都会遇到一个不希望出现的情况,应用程序会重新读取kafka总线上保留的所有消息。我设置属性 consumer.resetOffsets = true
以及 consumer.startOffset = true
. 起初,这些属性似乎解决了问题,但我能够重现它。我做错什么事了
1条答案
按热度按时间cbjzeqam1#
spring.cloud.stream.kafka.bindings..consumer.startoffset=最新
为我工作。