SpringKafka防止重复读取

Question

我使用Spring kafka 2. x读取来自kafka的消息。

我的问题是，如果我的方法在我的kafkalistener方法中花费了一段时间，那么kafka会发送相同的消息两次，这对我来说是个问题。我想要什么，如果我从Kafka读到消息，kafka不会向我发送这条消息第二次值，如 max.poll.interval.ms 不保证一次阅读消息。在Spring启动中实现一次阅读策略的正确方法是什么。在我的消息中，由于这个原因，我没有钥匙，我不能放一个控件。

@KafkaListener(topics = "mytopics",groupId = "mygroup",concurrency = 3",containerFactory = "MyListenerContainerFactory")
void messageReceiver(@Payload String data, @Headers MessageHeaders headers) {

  String receivedTopic=  headers.get(KafkaHeaders.RECEIVED_TOPIC).toString();

        //DO something
 
}

Answer 1

您需要在< code > max . poll . interval . ms 内处理轮询结果。所以增加它，或者减少< code>max.poll.records。

如果你花太长时间处理，Kafka没有机制来阻止重新交付。