Spring Boot对接Kafka代码

Spring Boot 和 Kafka 结合可以方便地构建生产者、消费者和消息队列应用。以下是一个简单的步骤说明如何在 Spring Boot 应用中集成 Kafka：

1. 添加依赖：首先，在你的 `pom.xml` 文件中添加 Spring Kafka 的依赖：

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

2. 配置：在 `application.properties` 或者 `application.yml` 中配置 Kafka 相关信息，如 broker 地址、主题名称等：

spring.kafka.bootstrap-servers=localhost:9092
spring.kafka.consumer.auto-offset-reset=earliest

3. 创建 producer 消费者组件：创建一个 KafkaProducer 实例来发送消息到指定主题，一个 KafkaTemplate 或 ConsumerFactory 来接收消息：

@Autowired
private KafkaTemplate<String, String> kafkaTemplate;

@Bean
public ConcurrentKafkaListenerContainerFactory<String, String> listenerContainerFactory() {
    ConcurrentKafkaListenerContainerFactory factory = new ConcurrentKafkaListenerContainerFactory<>();
    factory.setConsumerFactory(new DefaultKafkaConsumerFactory<>(consumerConfig()));
    return factory;
}

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

4. 发送消息（producer）：

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

5. 测试：启动应用，通过发送消息到 `testTopic`，然后消费端将接收到并处理这些消息。