时间戳

首页 > 解决方案 > KafkaListner initialoffset 消费已经确认的消息？

spring - KafkaListner initialoffset 消费已经确认的消息？

问题描述

我在 kafka 中有 465264 条记录，但我已经使用了所有消息并且也确认了，但是当我尝试使用初始偏移量开始消费时，在确认后它一次又一次地消费相同的消息。以下是我的代码：

@KafkaListener(
    id = "${kafka.buyers.product-sales-pricing.id}",
    groupId = "${kafka.buyers.group-id}",
    concurrency = "${kafka.buyers.concurrency}",
    topicPartitions = { @TopicPartition( topic = "${kafka.buyers.product-sales-pricing.topic}", partitionOffsets = @PartitionOffset( partition = "0", initialOffset = "465260" ) ) }
)
public void listen( List<String> messages, Acknowledgment ack ){}

yml配置：

spring:
    kafka:
      bootstrapServers: kafka.moglilabs.com:29092
      consumer:
        enable-auto-commit: false
        autoOffsetReset: earliest
        keyDeserializer: org.apache.kafka.common.serialization.StringDeserializer
        valueDeserializer: org.apache.kafka.common.serialization.StringDeserializer #spring message converter will take care of deserialization
        max-poll-records: 1000

标签： springspring-bootapache-kafkakafka-consumer-api

解决方案

推荐阅读