0

我有一个这样的curl命令我正在尝试做一个curl以在confluent kafka上创建一个主题我在理解这个curl语句时遇到问题，在官方文档中curl命令如下所示

$ curl "http://localhost:8082/topics/test"
  {"name":"test","num_partitions":3}

https://docs.confluent.io/2.0.0/kafka-rest/docs/intro.html#inspect-topic-metadata 我是否必须考虑 {"name":"test","num_partitions":3} 作为数据还是 curl 命令的一部分..？

4

1 回答 1

2

您正在使用 v2.0 的文档，我建议您使用最新的（目前为 5.5）

要创建主题，您可以使用 5.5 中添加的新 API：

curl -s -X POST 'http://localhost:8082/v3/clusters/rgfnzs2RS3O65A7VSpNatg/topics' \
--header 'Content-Type: application/vnd.api+json' \
--data-raw '{
  "data": {
    "attributes": {
      "topic_name": "rmoff_topic03",
      "partitions_count": 1,
      "replication_factor": 1
    }
  }
}'

您需要获取集群 ID（rgfnzs2RS3O65A7VSpNatg在上面的示例中），您可以使用

➜ curl -s -X GET 'localhost:8082/v3/clusters'| jq '.data[0].attributes.cluster_id'
"rgfnzs2RS3O65A7VSpNatg"

参考：v3 API 文档

要删除主题，请使用相应的 API：

curl -s -X DELETE 'http://localhost:8082/v3/clusters/rgfnzs2RS3O65A7VSpNatg/topics/rmoff_topic03'
于 2020-06-05T09:07:37.413 回答