apache-kafka - 为什么 Kafka REST 代理 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-TokenHeader 中传递 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 编码的“值”的值。例如像

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