无法使用Kafka Rest Proxy创建Kafka主题-HTTP 415不支持的媒体类型javax.ws.rs.No

Question

我遵循本文档。我可以得到集群的信息如下：

curl -sk -X GET "https://xx.xx.xx.xx:8443/v3/clusters/"

上一个请求运行良好。但是，当我尝试创建一个主题时，我会得到HTTP 415不支持的媒体类型javax.ws.rs.NotSupportedException错误

命令：

curl -sk -X POST 
-H "Content-Type: application/json" 
-d "{"topic_name":"test1","partitions_count":6,"replication_factor":3,"configs":[]}" 
"https://xx.xx.xx.xx:8443/v3/clusters/xxxxxxx/topics"

有人知道如何解决这个问题吗？

Answer 1

我遇到了同样的问题，这对我来说很有效。

curl -X POST -H "Content-Type: application/vnd.kafka.json.v2+json"
--data '{"records":[{"value":{"foo":"bar"}}]}' "https://localhost:8443/topics/test"

Answer 2

这篇博客文章中的例子对我有用：

POST http://localhost:8443/v3/clusters/<CLUSTER_ID>/topics
Content-Type: application/vnd.api+json
{
"data": {
"attributes": {
"topic_name": "topic",
"partitions_count": 1,
"replication_factor": 2,
"configs": []
}
}
}

因此，将内容类型更改为application/vnd.api+json并使用不同的请求体