如何使用 curl 在融合的 kafka 中创建带有分区的主题

Question

我有一个像这样给出的 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 命令的一部分..?

Answer 1

您使用的是文档的 v2.0，我推荐 latest (currently 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 docs

要删除主题，请使用 corresponding API：

curl -s -X DELETE 'http://localhost:8082/v3/clusters/rgfnzs2RS3O65A7VSpNatg/topics/rmoff_topic03'

如何使用 curl 在融合的 kafka 中创建带有分区的主题

How to create topic with partitions in confluent kafka using curl

apache-kafka

kafka-rest

confluent-platform