spring boot 如何整合kafka

Spring Boot 提供了对 Kafka 的自动配置，使得整合 Kafka 变得非常简单。下面是整合 Kafka 的基本步骤：

1. 添加 Kafka 相关依赖：在 pom.xml 文件中添加 Kafka 相关的依赖，包括 spring-kafka 和 kafka-clients 等。

<dependency>
    <groupId>org.springframework.kafka</groupId>
    <artifactId>spring-kafka</artifactId>
    <version>2.7.3</version>
</dependency>
<dependency>
    <groupId>org.apache.kafka</groupId>
    <artifactId>kafka-clients</artifactId>
    <version>2.8.0</version>
</dependency>

2. 配置 Kafka 连接：在 application.properties 文件中配置 Kafka 连接信息，包括 Kafka 服务器地址和端口号等。

makefileCopy codespring.kafka.bootstrap-servers=localhost:9092

3. 定义 Kafka 生产者：使用 @EnableKafka 注解开启 Kafka 相关配置，并定义 Kafka 生产者。可以使用 KafkaTemplate 来发送消息到 Kafka 队列中。

@EnableKafka
@Configuration
public class KafkaProducerConfig {
    @Bean
    public ProducerFactory<String, String> producerFactory() {
        Map<String, Object> configProps = new HashMap<>();
        configProps.put(ProducerConfig.BOOTSTRAP_SERVERS_CONFIG, "localhost:9092");
        configProps.put(ProducerConfig.KEY_SERIALIZER_CLASS_CONFIG, StringSerializer.class);
        configProps.put(ProducerConfig.VALUE_SERIALIZER_CLASS_CONFIG, StringSerializer.class);
        return new DefaultKafkaProducerFactory<>(configProps);
    }

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

4. 定义 Kafka 消费者：使用 @KafkaListener 注解定义 Kafka 消费者，并通过配置消费者组来实现负载均衡。

@Component
public class KafkaConsumer {
    @KafkaListener(topics = "test", groupId = "group1")
    public void consume(String message) {
        System.out.println("Received message: " + message);
    }
}

以上是 Spring Boot 整合 Kafka 的基本步骤，可以根据实际需求进行相应的配置和调整。在实际项目中，可以使用 Spring Boot 提供的 Kafka 相关注解和模板来实现更加复杂的逻辑。