apache-kafka - 在 Kafka 消息中添加自定义 header

我使用 kafka 生产者将文件转换为字节数组，将其作为消息发送。

我还需要为消息添加一些 header ，例如文件名、时间戳等，以便在消费者端我可以根据文件名和其他 header 处理消息。

我当前正在做的是创建一个对象，并将原始消息和 header 包装在其中，并将该对象作为消息发送到字节数组中。

我想知道是否有一种方法可以在发布消息时添加自定义 header ？

最佳答案

Kafka v0.11.0.0 添加了对自定义 header 的支持。

您可以在创建 ProducerRecord 时添加它们，如下所示:

new ProducerRecord(key, value, headers, ...)，其中 headers 的类型为 Iterable

关于apache-kafka - 在 Kafka 消息中添加自定义 header ，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/29025627/

相关文章：

apache-kafka - Apache Kafka 和支持的平台