【发布时间】:2017-11-10 03:36:11
【问题描述】:
在我的 spring-boot 应用程序中使用 Spring Cloud Stream 版本 Brooklyn.SR1 和 spring-cloud-starter-stream-kafka。每次重新启动我的应用程序时,我都会遇到不希望的情况,我的应用程序会重新读取所有保留在 Kafka 总线上的消息。我设置了属性consumer.resetOffsets = true 和consumer.startOffset = true。起初看起来这些属性解决了这种情况,但我能够重现它。粗暴地我做错了什么
【问题讨论】:
-
这个问题与标签
apache-kafka-streams有什么关系? -
spring.cloud.stream.kafka.bindings.input.consumer.configuration.auto.offset.reset= latests ?
标签: java spring apache-kafka kafka-consumer-api