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

Question

我有一个问题，我做了一个apache kafka消费者在Spring Boot消费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) {.....}

}

Answer 1

• 给每个监听器一个ID；将autostartup设置为false.
• 将容器属性IdleEventInterval设置为某个值。
• 添加@eventlistener方法以接收listenerContaineridleEvents-请参见https://docs.spring.io/spring-kafka/docs/2.5.3。release/reference/html/#events-consumment
• 根据需要使用KafkalistenerEndpointRegistry启动和停止容器（通过ID)。