springboot整合Kafka

Spring Boot可以通过使用Spring Kafka来实现与Kafka的整合。下面是一个简单的示例，演示如何在Spring Boot应用程序中使用Kafka。

首先，你需要在`pom.xml`文件中添加相应的依赖：

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

接下来，你需要在`application.properties`文件中配置Kafka相关的属性：

spring.kafka.bootstrap-servers=your-kafka-bootstrap-servers
spring.kafka.consumer.group-id=your-consumer-group-id
spring.kafka.producer.key-serializer=org.apache.kafka.common.serialization.StringSerializer
spring.kafka.producer.value-serializer=org.apache.kafka.common.serialization.StringSerializer
spring.kafka.consumer.key-deserializer=org.apache.kafka.common.serialization.StringDeserializer
spring.kafka.consumer.value-deserializer=org.apache.kafka.common.serialization.StringDeserializer

然后，你可以创建一个生产者来发送消息：

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

@Service
public class KafkaProducerService {

    private static final String TOPIC = "your-topic-name";

    @Autowired
    private KafkaTemplate<String, String> kafkaTemplate;

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

最后，你可以创建一个消费者来接收消息：

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

@Service
public class KafkaConsumerService {

    @KafkaListener(topics = "your-topic-name", groupId = "your-consumer-group-id")
    public void consumeMessage(String message) {
        // 处理接收到的消息
    }
}

通过这种方式，你可以在Spring Boot应用程序中实现与Kafka的整合。请注意，以上代码只是一个简单的示例，你需要根据你的实际情况进行适当的调整和扩展。