springboot整合kafka消费者

1. 添加依赖

在 `pom.xml` 中添加 Kafka 相关依赖。

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

2. 配置 Kafka

在 `application.properties` 中配置 Kafka 相关属性。

# Kafka 服务器地址
spring.kafka.bootstrap-servers=localhost:9092
# 消费者组 ID
spring.kafka.consumer.group-id=my-group
# 自动提交偏移量
spring.kafka.consumer.enable-auto-commit=true

3. 创建消费者

创建一个消费者类来监听 Kafka 主题并处理消息。

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

@Component
public class MyConsumer {
    @KafkaListener(topics = "my-topic")
    public void consume(String message) {
        System.out.println("Received message: " + message);
    }
}

在上面的代码中，我们使用 `@KafkaListener` 注解来定义一个监听器方法，指定要消费的主题名称。

4. 运行应用程序

现在我们可以运行应用程序并发送一些消息到 Kafka 主题。消费者将自动接收并处理这些消息。

@SpringBootApplication
public class MyApp {
    public static void main(String[] args) {
        SpringApplication.run(MyApp.class, args);
    }
}

以上就是 springboot 整合 kafka 消费者的基本步骤。通过以上步骤，我们可以轻松地创建一个消费者来监听 Kafka 主题并处理消息。