我有一个场景，我想在启动时使用写入 kafka 主题的最后一条消息。例如，如果有一个具有单个分区的“deal_config”主题，并且存在三个消息，例如 1 | 2 | 3，启动时，我只想消耗消息3。如果我将startOffset设置为latest，我只能消耗新消息。理想情况下，我的消费者应该读取分区中最新消息的偏移量并消耗它的-1。
最佳答案
Spring Cloud Stream 未公开该功能 - 您可以使用 @KafkaListener 代替，并带有 ConsumerSeekAware 监听器 as discussed in the Spring Kafka Reference Manual .
关于spring - SCS - 消费kafka中最后一条可用消息，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/45793283/