如何在Kafka中发送和接收XML格式的消息

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 编码 app 字节 xml解析