spring boot 整合kafka配置

要将Spring Boot和Kafka集成在一起，需要进行以下配置：

1. 首先，需要在pom.xml文件中添加以下依赖：

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

2. 然后，在application.properties文件中添加以下配置：

spring.kafka.bootstrap-servers=<kafka服务器地址>
spring.kafka.consumer.group-id=<消费者组ID>
spring.kafka.consumer.auto-offset-reset=earliest

其中，`bootstrap-servers`指定了Kafka服务器的地址，`consumer.group-id`指定了消费者组的ID，`consumer.auto-offset-reset`指定了消费者从哪个位置开始消费消息。

3. 接下来，需要创建一个KafkaTemplate bean，用于向Kafka发送消息。在配置类中添加以下代码：

@Bean
public KafkaTemplate<String, String> kafkaTemplate() {
    return new KafkaTemplate<>(producerFactory());
}

@Bean
public ProducerFactory<String, String> producerFactory() {
    Map<String, Object> configProps = new HashMap<>();
    configProps.put(ProducerConfig.BOOTSTRAP_SERVERS_CONFIG, "<kafka服务器地址>");
    configProps.put(ProducerConfig.KEY_SERIALIZER_CLASS_CONFIG, StringSerializer.class);
    configProps.put(ProducerConfig.VALUE_SERIALIZER_CLASS_CONFIG, StringSerializer.class);
    return new DefaultKafkaProducerFactory<>(configProps);
}

4. 最后，需要创建一个KafkaListener bean，用于监听来自Kafka的消息。在配置类中添加以下代码：

@KafkaListener(topics = "<要监听的topic>")
public void listen(ConsumerRecord<String, String> record) {
    // 处理消息
}

其中，`topics`指定了要监听的topic。

以上就是Spring Boot整合Kafka的基本配置。需要注意的是，Kafka的配置非常灵活，可以根据具体需求进行调整。