kafka集成springboot

Kafka与Spring Boot的集成可以通过Spring Kafka来实现。下面是一个简单的步骤来集成Kafka和Spring Boot：

1. 添加依赖：在Spring Boot项目的pom.xml文件中，添加以下依赖：

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

2. 配置Kafka连接：在Spring Boot项目的application.properties或application.yml文件中，配置Kafka连接信息，例如：

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

3. 创建生产者：使用`KafkaTemplate`来创建一个Kafka生产者，可以将消息发送到指定的主题。例如，创建一个名为`MyProducer`的类：

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.kafka.core.KafkaTemplate;
import org.springframework.stereotype.Component;

@Component
public class MyProducer {

    @Autowired
    private KafkaTemplate<String, String> kafkaTemplate;

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

4. 创建消费者：使用`@KafkaListener`注解来创建一个Kafka消费者，监听指定的主题，并处理接收到的消息。例如，创建一个名为`MyConsumer`的类：

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

@Component
public class MyConsumer {

    @KafkaListener(topics = "my-topic", groupId = "my-group")
    public void receiveMessage(String message) {
        // 处理接收到的消息
        System.out.println("Received message: " + message);
    }
}

以上是一个简单的Kafka与Spring Boot集成的示例。你可以根据自己的需求进行扩展和定制。希望对你有所帮助！如果还有其他问题，请继续提问。