apache-kafka - 为什么 Kafka REST Proxy API 不使用 JSON 格式的数据？

Question

我尝试使用 kafka rest API 访问消息中心实例。当我通过 Postman Client 发送发布请求并将 Content-Type 作为 application/vnd.kafka.json.v1+json 它给了我以下响应

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

有人可以帮我吗？我还在 X-Auth-Token header 中传递 api key 。

Answer 1

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

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

但在所有情况下，Message Hub REST 服务都希望内容的格式为

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

即“value”的值是 base64 编码的。例如。像

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