为什么 Kafka REST Proxy API 不消费 JSON 格式的数据？

Question

我尝试使用 kafka Rest API 访问消息中心实例。当我通过邮递员客户端发送帖子请求并给出以下响应Content-Type时application/vnd.kafka.json.v1+json

{
  "error_code": 415,
  "message": "HTTP 415 Unsupported Media Type"
}

有人可以帮我吗？我还在X-Auth-Token标头中传递 api 密钥。

Answer 1

生成消息时接受的内容类型是

"application/vnd.kafka.binary.v1+json"
"application/vnd.kafka.v1+json"
"application/vnd.kafka+json"
"application/json"

但在所有情况下，消息中心 REST 服务都希望内容格式为

"application/vnd.kafka.binary.v1+json"

即要进行 Base64 编码的“value”的值。例如类似的东西

{"records":[{"value":"YmxhaGJsYWg="}]}