查询kafkatopic信息

功能介绍

查询kafkatopic信息。

URI

• URI格式

  GET softcomai/datalake/collection/v1.0/taskConsole/kafkaInfo

• 参数说明

  无。

请求

• 请求样例

  https://ip:port/softcomai/datalake/collection/v1.0/taskConsole/kafkaInfo?taskId=d75ea6dda2e144bbb6f0289d5c6cac8f

• 参数说明

  参数名	是否必选	参数类型	备注
  taskId	必填	String	任务ID。

响应

• 响应样例

  {
  "success": true,
  "returnData": {
  "topic": "dataCollect_07c0712c6e00d55e0fbec01f9709fe20",
  "resources_infos": [
  {
  "resources": [
  {
  "type": "Kafka",
  "attributes": {
  "public_connect_address": "ip:port,ip:port,ip:port",
  "instance_id": "57d6b545-4912-418d-9b75-7144bbdceb4e",
  "kafka_manager_user": "manager",
  "passwd": "Abc@123",
  "private_connect_address": "192.168.21.249:9092,192.168.21.196:9092,192.168.21.5:9092",
  "name": "kafka-integration",
  "ssl_enable": "false",
  "management_connect_address": "https://ip:port",
  "status": "RUNNING"
  }
  }
  ],
  "status": "SUCCESS",
  "trial": false
  }
  ]
  }
  }

• 要素说明

  参数名	参数类型	备注
  success	Boolean	请求是否成功。
  returnData	String	返回值。
  topic	String	Kafka口令。
  resources_infos	Json	集成鉴权返回信息。

状态码

具体请参考状态码。