Spring Boot如何实现与KAFKA消息队列的集成示例？

本文共计546个文字，预计阅读时间需要3分钟。

这里使用Spring Kafka依赖和KafkaTemplate对象操作Kafka服务。一、添加依赖和配置项：

1.在Pom文件中添加依赖：

xml org.springframework.kafka spring-kafka

2.添加配置项：

propertiesspring.kafka.bootstrap-servers=kafka-broker1:9092,kafka-broker2:9092

这里使用 spring-kafka 依赖和 KafkaTemplate 对象来操作 Kafka 服务。

一、添加依赖和添加配置项

1.1、在 Pom 文件中添加依赖

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

1.2、添加配置项

spring: kafka: bootstrap-servers: 12.168.3.62:9092 # 指定kafka 代理地址，可以多个 producer: retries: 2 # 写入失败时，重试次数。当retris为0时，produce不会重复。