springboot整合kafuka

在Spring Boot中整合Kafka，首先需要在pom.xml文件中添加Kafka的依赖:

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

然后，你需要在application.properties或application.yml文件中配置Kafka的相关属性，如Kafka服务器地址、端口号等:

spring.kafka.bootstrap-servers=localhost:9092

接下来，在你的Spring Boot应用程序中创建Kafka的生产者和消费者。你可以使用`KafkaTemplate`类来发送消息，使用注解`@KafkaListener`来监听并消费消息。

下面是一个简单的示例代码：

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

@Component
public class KafkaProducer {

    @Autowired
    private KafkaTemplate<String, String> kafkaTemplate;

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

@Component
public class KafkaConsumer {

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

以上代码中，`KafkaProducer`类中的`sendMessage`方法用于发送消息，`KafkaConsumer`类中的`receiveMessage`方法用于接收消息。