有没有办法使用 Kafka Confluent REST API 使用 headers 生成 Kafka 消息？

Question

我正在尝试使用一些自定义 headers 向 Kafka 发送消息，但我找不到执行此操作的方法。根据 documatation，POST /topics/(string: topic_name) API 无法将自定义 headers 附加到消息。

有谁知道通过融合的 Kafka REST API 发送带有自定义 headers 的 Kafka 消息的方法？

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

POST /topics/stream.mycustomtopic

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

Answer 1

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

Is there a way to produce Kafka messages with headers using Kafka Confluent REST API?