SCS - 消费 kafka 中的最后一条可用消息
SCS - to consume the last available message in kafka
我有一个场景，我想在启动时使用写入到 kafka 主题的最后一条消息。例如，如果有一个 "deal_config" 单分区主题，并且有三个消息，如 1 | 2 | 3，在启动时，我只想使用消息 3。如果我设置为 startOffset latest 我只能消费新消息。理想情况下，我的消费者应该读取分区中最新消息的偏移量并使用其中的 -1。
一位智者曾说过，看说明书... http://docs.spring.io/spring-cloud-stream/docs/Ditmars.BUILD-SNAPSHOT/reference/htmlsingle/#_kafka_consumer_properties
Spring Cloud Stream 未公开该功能 - 您可以改用 @KafkaListener，并使用 ConsumerSeekAware 侦听器 as discussed in the Spring Kafka Reference Manual。
我有一个场景，我想在启动时使用写入到 kafka 主题的最后一条消息。例如，如果有一个 "deal_config" 单分区主题，并且有三个消息，如 1 | 2 | 3，在启动时，我只想使用消息 3。如果我设置为 startOffset latest 我只能消费新消息。理想情况下，我的消费者应该读取分区中最新消息的偏移量并使用其中的 -1。
一位智者曾说过，看说明书... http://docs.spring.io/spring-cloud-stream/docs/Ditmars.BUILD-SNAPSHOT/reference/htmlsingle/#_kafka_consumer_properties
Spring Cloud Stream 未公开该功能 - 您可以改用 @KafkaListener，并使用 ConsumerSeekAware 侦听器 as discussed in the Spring Kafka Reference Manual。