小编Arm*_*ich的帖子

我正在尝试使用一些自定义标头向 Kafka 发送消息，但我找不到方法。根据文档，POST /topics/(string: topic_name)API 无法将自定义标头附加到消息。

有谁知道如何通过融合的 Kafka REST API 发送带有自定义标头的 Kafka 消息？

这是我发送到 REST 代理的示例请求正文

POST /topics/stream.mycustomtopic

{
    "records": [{
        "value": "{\"myFirstKey\":\"myFirstValue\"}"
    }]
}