Spring Boot中@KafkaListener使用${}动态指定topic

项目场景：

在Spring Kafka中，我们可以使用

${}

来引用Spring的属性配置。这样我们就可以在不同的环境中重新配置topic名称，而不需要修改代码。

解决方案：

在application.properties或application.yml中定义topic名称：

# application.properties
kafka.topic=myTopic

然后在你的代码中使用

${}

来引用这个属性：

@KafkaListener(topics = "${kafka.topic}")
public void listen(String message) {
    System.out.println("Received message in topic : " + message);
}

如果你使用的是多个topic，你可以使用

;

来分割多个topic名称：

# application.properties
kafka.topics=topic1;topic2;topic3

然后在你的代码中使用

${}

来引用这个属性：

@KafkaListener(topics = "${kafka.topics}")
public void listen(String message) {
    System.out.println("Received message in topic : " + message);
}