Kafka 实战 - SpringBoot 中使用@KafkaListener详解与使用

import org.springframework.kafka.annotation.KafkaListener;
import org.springframework.stereotype.Component;
 
@Component
public class KafkaConsumer {
 
    // 定义消费者组
    private static final String GROUP_ID = "my-group";
 
    // 定义topic
    private static final String TOPIC = "myTopic";
 
    // 使用@KafkaListener注解创建消息监听器
    @KafkaListener(topics = TOPIC, groupId = GROUP_ID)
    public void listen(String message) {
        System.out.println("Received message in group " + GROUP_ID + ": " + message);
    }
}

这段代码演示了如何在Spring Boot应用程序中使用@KafkaListener注解来创建一个简单的Kafka消费者。它定义了一个消费者组my-group和要监听的topicmyTopic。当有消息发送到myTopic时，listen方法会被触发，并打印出接收到的消息内容。这是一个入门级的例子，展示了如何在Spring应用程序中接收Kafka消息。