springboot 接入kafka

要在Spring Boot中接入Kafka，你需要按照以下步骤进行配置和编码：

1. 在你的Spring Boot项目的pom.xml文件中添加Kafka相关的依赖项：

<dependency>
  <groupId>org.springframework.kafka</groupId>
  <artifactId>spring-kafka</artifactId>
</dependency>
<dependency>
  <groupId>org.springframework.kafka</groupId>
  <artifactId>spring-kafka-test</artifactId>
  <scope>test</scope>
</dependency>
<dependency>
  <groupId>org.apache.kafka</groupId>
  <artifactId>kafka-clients</artifactId>
  <version>3.4.0</version>
</dependency>

2. 创建一个Kafka配置类，用于配置Kafka的连接信息和其他相关配置项。

3. 创建一个Kafka生产者类，用于发送消息到Kafka集群。你可以使用`KafkaTemplate`来发送消息。

4. 创建一个Controller类，用于测试你构建的Kafka生产者类。在这个Controller类中，你可以定义一个接口，用于接收请求并将消息发送到Kafka集群。

下面是一个示例的Controller类的代码：

@RestController
public class KafkaTestController {

  private static final Logger kafkaTestLog = LoggerFactory.getLogger(KafkaTestController.class);

  @Resource
  private KafkaProducer kafkaProducer;

  @GetMapping("/kafkaTest")
  public void kafkaTest(String msg, String topic) {
    kafkaProducer.producer(msg, topic);
    kafkaTestLog.info("接收到消息 {} {}", msg, topic);
  }
}