为什么 Kafka REST 代理 API 不消费 JSON 格式的数据

Question

我尝试使用 kafka rest API 访问消息中心实例。 当我通过邮递员客户端发送 post 请求并按application/vnd.kafka.json.v1+json提供Content-Type时，它给了我以下响应

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

谁能帮我？我还在标头中传递 api 密钥X-Auth-Token。

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 编码的"值"的值。例如，类似的东西

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