小伙伴们，今天来聊聊如何用 SpringBoot 玩转 Kafka！🤩 Kafka 是一个超强大的分布式消息系统，而 SpringBoot 的轻量级框架让它变得超级易用。想让自己的项目支持异步通信？那 Kafka 绝对是你的首选！🚀

首先，别忘了引入依赖！在 `pom.xml` 中添加 Kafka 和 Spring Boot Starter 的相关依赖：

```xml

org.springframework.kafka

spring-kafka

```

接下来，配置 `application.yml` 文件，填入 Kafka 的地址和主题信息：

```yaml

spring:

kafka:

bootstrap-servers: localhost:9092

consumer:

group-id: test-group

auto-offset-reset: earliest

```

写个简单的生产者试试？用 `KafkaTemplate` 发送消息，代码简洁到让你怀疑人生：

```java

@Service

public class KafkaProducer {

@Autowired

private KafkaTemplate kafkaTemplate;

public void sendMessage(String topic, String message) {

kafkaTemplate.send(topic, message);

}

}

```

消费者也一样简单，用注解 `@KafkaListener` 轻松搞定！👇

是不是感觉 SpringBoot 操作 Kafka 超级方便？👏 快去试试吧！💪

SpringBoot Kafka 消息队列