Kafka可正常收发XML消息，关键在序列化与反序列化：发送端用StringSerializer将规范XML字符串（UTF-8编码）发送；接收端用StringDeserializer获取字符串后，再用Jackson XML等解析为对象；需统一编码、注意字符转义、避免超大消息。
Kafka本身不关心消息内容格式，XML消息可以像字符串或字节数组一样正常收发，关键在于序列化与反序列化环节的正确处理。
发送端：把XML转成String或byte[]再发
推荐使用 StringSerializer，前提是XML内容不含非法控制字符且编码统一（如UTF-8）：
- 构造XML字符串时确保格式规范，例如用
<user><id>123</id><name>张三</name></user> - 在
application.yml中配置生产者序列化器：
spring.kafka.producer.value-serializer=org.apache.kafka.common.serialization.StringSerializer - 调用
kafkaTemplate.send(topic, xmlString)即可，无需额外编码转换
接收端：按String接收后解析XML
消费者同样用 StringDeserializer，拿到字符串后再用标准XML解析器处理：
Apache Superset Dashboard and SQL Exploration Skill
下载
Apache Superset 是一个广泛采用的开源 BI 平台，用于 SQL 探索、图表构建和仪表板交付。当代理需要查询仓库数据、组装仪表板或使用成熟的分析界面解释指标而不是临时笔记本代码时，此技能非常有用。
- 配置项：
spring.kafka.consumer.value-deserializer=org.apache.kafka.common.serialization.StringDeserializer - 在
@KafkaListener方法中直接接收String类型参数 - 用
DocumentBuilder、JAXB或Jackson XML Module解析字符串为对象，例如：
JacksonXmlModule module = new JacksonXmlModule();<br> XmlMapper mapper = new XmlMapper(module);<br> User user = mapper.readValue(xmlString, User.class);
注意事项：避免常见坑
XML消息虽简单，但几个细节容易出错：
- 编码必须一致：生产端写入和消费端读取都用 UTF-8，否则中文变乱码
- 不要手动base64或gzip封装：除非业务强制要求，否则增加复杂度且无必要
-
注意特殊字符转义：如
&要写成&，否则XML解析失败 - 大XML慎用：单条消息建议不超过1MB（Kafka默认限制），超长需分片或存OSS后传URL
进阶：用自定义序列化器统一处理XML
若项目中XML消息频繁出现，可封装复用逻辑：
- 实现
Serializer<myxmlobject></myxmlobject>和Deserializer<myxmlobject></myxmlobject> - 内部用
XmlMapper完成对象 ↔ XML字符串 ↔ byte[] 的双向转换 - 注册到
ProducerFactory/ConsumerFactory中，后续直接发送/接收对象
