springstreamKafka重新读取所有消息

wz3gfoph  于 2021-06-07  发布在  Kafka
关注(0)|答案(1)|浏览(238)

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

cbjzeqam

cbjzeqam1#

spring.cloud.stream.kafka.bindings..consumer.startoffset=最新
为我工作。

相关问题