kafka不直接消费xml文件流，而是通过上传接口接收xml并作为字节序列发送到topic，下游消费者拉取后自行解析；需统一utf-8编码、避免同步发送、复用解析器，并推荐对象存储存大xml、kafka仅传url。
Kafka 本身不直接消费“XML 文件流”，它只收发字节序列（byte[]）。所谓“消费 XML 文件流”，本质是：你有一个上传接口接收 XML（如 POST /upload），服务端解析/校验后，把 XML 内容作为消息体（value）发到 Kafka Topic；下游消费者从 Topic 拉取该字节流，再按需解析为 XML 文档或对象。
上传接口如何把 XML 推送到 Kafka Topic
关键不是“推送 XML 文件”，而是把 HTTP 请求体中的 XML 字符串（或原始字节）序列化为 Kafka 消息。常见错误是直接传文件句柄、InputStream 或未编码的 DOM 对象——Kafka Producer 只接受 byte[] 或能转成它的类型（如 String）。
- 用
StringSerializer时，确保 XML 字符串编码统一（推荐 UTF-8），避免乱码：props.put("key.serializer", "org.apache.kafka.common.serialization.StringSerializer"); props.put("value.serializer", "org.apache.kafka.common.serialization.StringSerializer"); - 若 XML 较大（>1MB），建议改用
ByteArraySerializer并手动指定编码：byte[] xmlBytes = xmlString.getBytes(StandardCharsets.UTF_8); producer.send(new ProducerRecord<>("xml-topic", key, xmlBytes)); - 别在上传接口里同步调用
producer.send(...).get()—— 阻塞主线程且易超时；用回调（Callback）或异步日志记录发送结果
Kafka Consumer 怎么解析收到的 XML 消息
Consumer 收到的是 ConsumerRecord<string byte></string> 或 ConsumerRecord<string string></string>，解析 XML 的责任完全在业务代码，Kafka 不参与。
