SpringBoot整合kafka

Spring Boot 提供了 Kafka 的自动配置，方便我们在项目中使用 Kafka。下面是整合 Kafka 的步骤：

1. 引入依赖

在 pom.xml 文件中添加以下依赖：

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

2. 配置 Kafka

在 application.yml 文件中添加 Kafka 的配置：

spring:
  kafka:
    bootstrap-servers: localhost:9092
    consumer:
      group-id: group
      auto-offset-reset: earliest

- `bootstrap-servers`: Kafka 的地址，这里使用本地的地址。
- `consumer.group-id`: 消费者组的 ID。
- `consumer.auto-offset-reset`: 自动重置偏移量，earliest 表示从最早的记录开始消费。

3. 发送消息

使用 `KafkaTemplate` 发送消息：

@Autowired
private KafkaTemplate<String, String> kafkaTemplate;

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

在 `send()` 方法中指定要发送的主题和消息内容。

4. 接收消息

使用 `@KafkaListener` 注解来监听主题上的消息：

@KafkaListener(topics = "myTopic", groupId = "group")
public void receiveMessage(String message) {
    System.out.println("Received message: " + message);
}

在 `@KafkaListener` 注解中指定要监听的主题和消费者组的 ID。当有消息到达主题时，`receiveMessage()` 方法会被调用来处理消息。

以上就是 Spring Boot 整合 Kafka 的步骤。