apache-kafka - 有没有办法使用 Kafka Confluent 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来设置标头。