如何在spring boot中按顺序消费kafka主题

【问题标题】：how to consume kafka topics in sequence in spring boot如何在spring boot中按顺序消费kafka主题
【发布时间】：2020-10-17 06:36:55
【问题描述】：

我有一个问题，我在 spring boot 中创建了一个 apache kafka 消费者来消费 3 个不同的主题。但是我需要先消费第一个主题的所有数据，然后再消费以下主题的数据，有什么办法吗？还是你会一直以同样的方式阅读它们？

@Component
public class KafkaTestListener {

@KafkaListener(topics = "${message.topic.name}", groupId = "${message.group.name}")
    public void listenTopic1(String message) {....}

@KafkaListener(topics = "${message.topic.name2}", groupId = "${message.group.name}")
    public void listenTopic3(String message) {....}

@KafkaListener(topics = "${message.topic.name3}", groupId = "${message.group.name}")
    public void listenTopic3(String message) {.....}

}

【问题讨论】：

标签： spring-boot apache-kafka spring-kafka

【解决方案1】：

给每个听众一个id；将autoStartup 设置为false。
将容器属性idleEventInterval 设置为某个值。
添加@EventListener 方法来接收ListenerContainerIdleEvents - 请参阅https://docs.spring.io/spring-kafka/docs/2.5.3.RELEASE/reference/html/#events 和https://docs.spring.io/spring-kafka/docs/2.5.3.RELEASE/reference/html/#event-consumption
根据需要使用KafkaListenerEndpointRegistry 启动和停止容器（通过id）。

【讨论】：