有没有办法使用 Kafka Confluence REST API 生成带有标头的 Kafka 消息？

Question

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

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

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

POST /topics/stream.mycustomtopic

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

Answer 1

您是对的，REST 代理当前不支持 Kafka 标头。您需要使用Producer API来设置标头。