我正在尝试使用一些自定义标头向 Kafka 发送消息，但我找不到方法。根据文档, The POST /topics/(string: topic_name)API 无法将自定义标头附加到消息。
有谁知道如何通过融合的 Kafka REST API 发送带有自定义标头的 Kafka 消息？
这是我发送到 REST 代理的示例请求正文
POST /topics/stream.mycustomtopic
{
"records": [{
"value": "{\"myFirstKey\":\"myFirstValue\"}"
}]
}
您是对的，REST 代理当前不支持 Kafka 标头。您需要使用生产者API设置标题。
本文内容由网友自发贡献，版权归原作者所有，本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容，请联系:hwhale#tublm.com(使用前将#替换为@)
