一、引言
在 Spring Boot 项目中，Kafka 是常用的消息队列，可实现高效的消息传递。本文介绍三种在 Spring Boot 中使用 Kafka 发送消息的方式，分析各自优缺点，并给出对应的 pom.xml 依赖。
二、依赖引入
在 pom.xml 中添加以下依赖：
<dependencies><!-- Spring Boot Starter for Kafka --><dependency><groupId>org.springframework.kafka</groupId><artifactId>spring-kafka</artifactId><version>3.0.8</version></dependency><!-- JSON 处理库，这里使用的是 org.json --><dependency><groupId>org.json</groupId><artifactId>json</artifactId><version>20231013</version></dependency>
</dependencies>
若要进行测试，可添加 spring-kafka-test 依赖：
<dependency><groupId>org.springframework.kafka</groupId><artifactId>spring-kafka-test</artifactId><scope>test</scope>
</dependency>
三、三种消息发送方式
（一）自定义 KafkaMessageSender 类
1. 代码示例
import org.apache.kafka.clients.producer.*;
import org.json.JSONObject;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import java.util.Properties;class TsSign {private int id;private String deviceId;public TsSign(int id, String deviceId) {this.id = id;this.deviceId = deviceId;}
}class TsSignSerializer {// 序列化逻辑
}public class KafkaMessageSender {private static final Logger log = LoggerFactory.getLogger(KafkaMessageSender.class);private final Producer<
