search

spring-cloud / spring-cloud-stream-binder-kafka

Spring Cloud Stream binders for Apache Kafka and Kafka Streams
Apache License 2.0
331 stars 301 forks source link

Repeated consumption of a previous successful consumption every 5 minutes for half an hour #1184

Open hero-zhanghao opened 2 years ago

hero-zhanghao commented 2 years ago

Spring boot Version : 2.5.0 Spring Cloud Version ： 2020.0.3

I used Spring-Cloud-stream-binder - Kafka and Spring-cloud-stream-binder - Kafka-Streams for kafka production and consumption in the project.

I found in the log that several messages were repeatedly consumed, and they were under a group.

This keeps happening once every 5 minutes, a total of 5 repetitions of consume, plus the initial consume, a total of 6 times, a total of half an hour.

I configured the retry policy to be a maximum of 3 times and then sent to DLQ, but no error message was found.

What is the cause of this, or is there any way to help find some clues.