springboots集成kafka

### Spring Boot 集成 Kafka 示例教程 #### 1. 添加 Maven 或 Gradle 依赖 为了使 Spring Boot 应用程序能够与 Kafka 进行交互，需在 `pom.xml` 文件中添加相应的依赖项[^1]。 对于 Maven 用户： ```xml <dependency> <groupId>org.springframework.kafka</groupId> <artifactId>spring-kafka</artifactId> </dependency> ``` Gradle 用户则应在 build.gradle 中加入如下语句: ```groovy implementation 'org.springframework.kafka:spring-kafka' ``` #### 2. 配置 Kafka 属性 接下来，在 `application.properties` 或 `application.yml` 文件内指定必要的 Kafka 设置参数[^2]。 采用 properties 格式的配置样例如下所示： ```properties spring.kafka.bootstrap-servers=localhost:9092 spring.kafka.consumer.group-id=my-group spring.kafka.consumer.auto-offset-reset=earliest ``` YAML 版本的配置同样简单明了： ```yaml spring: kafka: bootstrap-servers: localhost:9092 consumer: group-id: my-group auto-offset-reset: earliest ``` #### 3. 创建 Kafka 生产者服务类 定义一个用于发送消息到特定主题的服务组件。这里给出的是 Java 实现的例子[^4]: ```java @Service public class KafkaProducerService { @Autowired private KafkaTemplate<String, String> kafkaTemplate; public void sendMessage(String topicName, String message){ this.kafkaTemplate.send(topicName,message); } } ``` #### 4. 构建消费者逻辑 编写监听器来接收来自某个主题的消息并执行相应操作。下面是一个简单的例子说明如何做到这一点: ```java @Component public class KafkaConsumerListener { @KafkaListener(topics = "${kafka.topic.name}", groupId="${spring.kafka.consumer.group-id}") public void listen(ConsumerRecord<?, ?> record) { System.out.printf("key = %s, value = %s%n", record.key(), record.value()); } } ``` 通过上述步骤即可完成基本的 Spring Boot 和 Kafka 的集成工作。这不仅有助于理解两者之间的协作机制，也为后续开发更复杂的应用场景打下了坚实的基础。