Spring Cloud Kafka 消息监听：入门教程

本教程将指导您如何在 Spring Cloud 中使用 Spring Kafka 监听 Kafka 消息。以下是一个简单的示例，展示了如何配置和使用 Kafka 监听器。

1. 添加依赖项

在您的 pom.xml 文件中添加以下依赖项：

<dependency>
    <groupId>org.springframework.kafka</groupId>
    <artifactId>spring-kafka</artifactId>
    <version>2.5.2.RELEASE</version>
</dependency>

2. 创建 Kafka 配置

在 application.properties 文件中添加以下 Kafka 配置：

spring.kafka.consumer.bootstrap-servers=localhost:9092
spring.kafka.consumer.group-id=my-group

3. 创建消息监听器

创建一个消息监听器，实现 KafkaListener 接口：

@Component
public class MyKafkaListener {

    @KafkaListener(topics = 'my-topic')
    public void listen(String message) {
        System.out.println('Received message: ' + message);
    }
}

在上面的示例中，我们监听了名为 my-topic 的 Kafka 主题，并在接收到消息时打印出消息内容。

4. 启动应用程序

启动 Spring Boot 应用程序后，您应该能够看到消息监听器已经开始接收来自 Kafka 的消息。

总结

以上就是在 Spring Cloud 中监听 Kafka 消息的基本步骤。您可以根据自己的需求进行更改和扩展。