springboot整合kafka消费消息

在Spring Boot中整合Kafka并消费消息的步骤如下：

1. 首先，确保您已经在Spring Boot项目中添加了Kafka的依赖。在pom.xml文件中添加以下依赖项：

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

2. 创建一个Kafka消费者类，使用`@KafkaListener`注解来指定监听的主题和消费者组。例如：

import org.springframework.kafka.annotation.KafkaListener;
import org.springframework.stereotype.Component;

@Component
public class KafkaConsumer {

    @KafkaListener(topics = "your_topic_name", groupId = "your_consumer_group")
    public void consume(String message) {
        // 在这里处理接收到的消息
        System.out.println("Received message: " + message);
    }
}

3. 在application.properties（或application.yml）文件中配置Kafka相关的属性。例如：

spring.kafka.bootstrap-servers=localhost:9092

4. 确保Kafka服务器正在运行，并且您已经创建了要消费的主题。

5. 启动您的Spring Boot应用程序，Kafka消费者将自动开始监听配置的主题并消费消息。

这样，您就完成了Spring Boot与Kafka的整合，并可以消费Kafka发送的消息了。您可以根据需要在`consume`方法中添加逻辑来处理接收到的消息。