如何在Kafka REST代理中从命令行创建主题

Question

我使用的是Kafka rest代理，但不是整个融合平台，只是Kafka与我的Kafka经纪人休息。但是我无法通过下面的命令从命令行创建主题。

bin/kafka-topics.sh --create --bootstrap-server localhost:9092 --replication-factor 1 --partitions 1 --topic test.

我想知道还有别的出路吗。

Answer 1

您尝试过的命令不是要与Kafka的REST代理服务器交互，而是直接与Kafka集群交互。

根据汇合REST代理API引用，只有在REST代理API v3中才有可能创建一个主题，该v3目前可以作为预览功能使用。

“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"

在其中，可以使用

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