在 Apache Kafka 中,使用 KafkaListener 可以方便地消费多个 topic。
在 Spring Kafka 中,您可以使用 @KafkaListener 注解来标识方法,以便消费消息。您可以使用多个 @KafkaListener 注解来监听不同的 topic,例如:
@KafkaListener(topics = "topic1")
public void listenTopic1(String message) {
// handle message for topic1
@KafkaListener(topics = "topic2")
public void listenTopic2(String message) {
// handle message for topic2
您也可以使用一个 @KafkaListener 注解,并通过 topics 参数指定多个 topic,例如:
@KafkaListener(topics = {"topic1", "topic2"})
public void listenMultipleTopics(String message) {
// handle message for multiple topics
在监听方法中,您可以获取到消息的内容,并对其进行处理。