是否可以使用 Kafka Rest Proxy 创建主题？

Question

我正在尝试从 Kafka Rest Proxy 创建一个主题，但我没有看到任何相关文档。我希望有一种方法可以做到这一点，因此我不需要以不同于所有其他通信的方式以编程方式创建主题。有谁知道这是否可能？

我在这里没有看到任何文档：http : //docs.confluent.io/1.0/kafka-rest/docs/api.html。

谢谢你的帮助。

Answer 1

借助 REST 代理 API 的第 3 版，现在可以实现。

根据Confluent REST Proxy API Reference，可以使用当前作为预览功能提供的 REST Proxy API v3 创建主题。

下面提供了一个主题创建请求的示例，并记录在此处：

POST /v3/clusters/cluster-1/topics HTTP/1.1
Host: kafkaproxy.example.com
Content-Type: application/vnd.api+json
Accept: application/vnd.api+json

{
  "data": {
    "attributes": {
      "topic_name": "topic-1",
      "partitions_count": 2,
      "replication_factor": 3,
      "configs": [
        {
          "name": "cleanup.policy",
          "value": "compact"
        }
      ]
    }
  }
}

使用curl：

curl -X POST -H "Content-Type: application/vnd.api+json" -H "Accept: application/vnd.api+json" \
          --data '{"data":{"attributes": {"topic_name": "topic-1", "partitions_count": 2, "replication_factor": 1, "configs": [{"name": "cleanup.policy","value": "compact"}]}}}' \
          "http://localhost:8082/v3/clusters/<cluster-id>/topics"

其中cluster-id可以使用识别

curl -X GET -H "Accept: application/vnd.api+json" localhost:8082/v3/clusters

Answer 2

不。问题是没有创建主题的协议支持（至少现在还没有）。请参阅我之前的问题，并阅读评论。