spring boot整合kafka

好的，让我来回答你的问题。在 Spring Boot 中，我们可以通过使用 spring-kafka 库来整合 Kafka。首先，需要在 pom.xml 中添加以下依赖：

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

然后，需要在 application.properties 文件中配置 Kafka 连接信息，比如：

spring.kafka.bootstrap-servers=localhost:9092
spring.kafka.consumer.group-id=myGroup
spring.kafka.consumer.auto-offset-reset=earliest
spring.kafka.producer.value-serializer=org.apache.kafka.common.serialization.StringSerializer
spring.kafka.consumer.value-deserializer=org.apache.kafka.common.serialization.StringDeserializer

在代码中，我们可以使用 @KafkaListener 注解监听一个 Kafka 主题：

@Service
public class MyKafkaListener {

    @KafkaListener(topics = "myTopic")
    public void listen(String message) {
        System.out.println("Received message: " + message);
    }
}

当有消息发送到 "myTopic" 主题时，这个方法就会被调用。

如果需要发送消息，可以使用 KafkaTemplate：

@Service
public class MyKafkaProducer {

    @Autowired
    private KafkaTemplate<String, String> kafkaTemplate;

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

以上就是在 Spring Boot 中整合 Kafka 的简单示例。希望能对你有所帮助！