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

Question

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

有没有人知道通过融合的Kafka REST API发送带有自定义标头的Kafka消息的方法？

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

POST /topics/stream.mycustomtopic

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

Answer 1

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