springboot整合kafka

Spring Boot可以很方便地与Kafka集成，以下是整合步骤：

1. 添加Kafka依赖

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

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

2. 配置Kafka

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

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

3. 创建Kafka生产者

使用Spring Kafka提供的KafkaTemplate类创建生产者：

@Autowired
private KafkaTemplate<String, String> kafkaTemplate;

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

4. 创建Kafka消费者

使用@KafkaListener注解创建消费者：

@KafkaListener(topics = "my-topic", groupId = "my-group")
public void consume(String message) {
    System.out.println("Received message: " + message);
}

以上就是Spring Boot整合Kafka的基本步骤，可以根据实际需求进行配置和扩展。