springboot 引入kafka

要在Spring Boot项目中引入Kafka，可以按照以下步骤进行操作：

1. 添加Kafka依赖

在项目的pom.xml文件中添加Kafka依赖：

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

2. 配置Kafka

在application.properties或application.yml文件中添加Kafka相关配置：

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

3. 创建Kafka Producer

使用Spring Kafka提供的KafkaTemplate类创建Kafka Producer，可以使用以下代码：

@Autowired
private KafkaTemplate<String, String> kafkaTemplate;

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

4. 创建Kafka Consumer

使用Spring Kafka提供的@KafkaListener注解创建Kafka Consumer，可以使用以下代码：

@KafkaListener(topics = "myTopic", groupId = "myGroup")
public void listen(String message) {
    // 处理消息
}

通过以上步骤，就可以在Spring Boot项目中引入Kafka并实现消息的生产和消费。