SpringBoot整合kafka

Spring Boot可以很方便地整合Kafka，只需要引入相关的依赖和进行一些配置即可。

1. 引入依赖

在pom.xml文件中引入Kafka的依赖：

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

2. 配置Kafka

在application.properties文件中配置Kafka：

# Kafka配置
spring.kafka.bootstrap-servers=localhost:9092 # Kafka集群地址
spring.kafka.consumer.group-id=my-group # 消费者组ID

3. 创建消息生产者

使用Spring Boot的自动配置机制，可以很方便地创建Kafka消息生产者。只需要创建一个KafkaTemplate对象，然后在需要发送消息的地方调用它的send方法即可。

@Autowired
private KafkaTemplate<String, String> kafkaTemplate;

public void sendMessage(String topic, String message) {
    kafkaTemplate.send(topic, message);
}

4. 创建消息消费者

使用Spring Boot的自动配置机制，可以很方便地创建Kafka消息消费者。只需要在需要接收消息的类中添加@KafkaListener注解，指定要监听的主题和方法即可。

@KafkaListener(topics = "my-topic", groupId = "my-group")
public void handle(String message) {
    // 处理消息
}

以上就是Spring Boot整合Kafka的基本步骤，可以根据实际需求进行更加详细的配置和操作。