如何创建一个带有spring start的Kafka消费者侦听器，在消息被拒绝的情况下，在可变时间后重试消费它们

<dependency>
    <groupId>org.springframework.kafka</groupId>
    <artifactId>spring-kafka</artifactId>
</dependency>

import org.springframework.kafka.annotation.KafkaListener;
import org.springframework.stereotype.Component;

@Component
public class KafkaConsumer {

    @KafkaListener(topics = "your_topic_name")
    public void consume(String message) {
        // 处理接收到的消息
        // 如果消息处理失败，可以抛出异常或返回错误码
    }
}

import org.springframework.retry.annotation.Retryable;
import org.springframework.stereotype.Component;

@Component
public class KafkaConsumer {

    @Retryable(maxAttempts = 3, backoff = @Backoff(delay = 1000))
    public void consume(String message) {
        // 处理接收到的消息
        // 如果消息处理失败，可以抛出异常或返回错误码
    }
}

spring.kafka.bootstrap-servers=your_kafka_bootstrap_servers
spring.kafka.consumer.group-id=your_consumer_group_id