【问题标题】:Spring Stream Kafka re-reads all messagesSpring Stream Kafka 重新读取所有消息
【发布时间】: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


【解决方案1】:

spring.cloud.stream.kafka.bindings..consumer.startOffset = 最新的

为我工作。

【讨论】:

    猜你喜欢
    • 2018-01-04
    • 2022-01-06
    • 2020-12-25
    • 2021-06-12
    • 1970-01-01
    • 1970-01-01
    • 1970-01-01
    • 2021-07-09
    • 1970-01-01
    相关资源
    最近更新 更多