gpt4 book ai didi

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

转载 作者:行者123 更新时间:2023-12-02 21:51:35 27 4
gpt4 key购买 nike

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

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

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

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

最佳答案

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

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

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

更多详情请参见:

https://issues.apache.org/jira/browse/KAFKA-4208

https://cwiki.apache.org/confluence/display/KAFKA/KIP-82+-+Add+Record+Headers

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

27 4 0
Copyright 2021 - 2024 cfsdn All Rights Reserved 蜀ICP备2022000587号
广告合作:1813099741@qq.com 6ren.com