【问题标题】:Why Kafka REST Proxy API not Consuming data in JSON Format?为什么 Kafka REST 代理 API 不使用 JSON 格式的数据?
【发布时间】:2017-05-24 17:54:38
【问题描述】:
我正在尝试使用 kafka rest API 访问消息中心实例。当我通过邮递员客户端发送帖子请求并将Content-Type 作为application/vnd.kafka.json.v1+json 时,它给了我以下响应
{
"error_code": 415,
"message": "HTTP 415 Unsupported Media Type"
}
有人可以帮我吗?
我还在X-Auth-Token Header 中传递了 api 密钥。
【问题讨论】:
标签:
apache-kafka
message-hub
【解决方案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"
即"value" 的值是 base64 编码的。
例如。像
{"records":[{"value":"YmxhaGJsYWg="}]}