异构管理
kafka监控 kafka消费
示例接口
示例接口描述
URL
Method
Request
| 名称 | 类型 | 必选 | 初始值 | 简介 | Mock规则 |
| foo | String | 否 | @ctitle | 请求属性示例 | |
Response
| 名称 | 类型 | 必选 | 初始值 | 简介 | Mock规则 |
| string | String | 否 | ★ | 字符串属性示例 | 1-10 |
| number | Number | 否 | 1 | 数字属性示例 | 1-100 |
| boolean | Boolean | 否 | true | 布尔属性示例 | 1-2 |
| regexp | RegExp | 否 | /[a-z][A-Z][0-9]/ | 正则属性示例 | |
| function | Function | 否 | () => Math.random() | 函数属性示例 | |
| array | Array | 否 | | 数组属性示例 | 1-10 |
| foo | Number | 否 | 1 | 数组元素示例 | +1 |
| bar | String | 否 | ★ | 数组元素示例 | 1-10 |
| items | Array | 否 | [1, true, 'hello', /\w{10}/] | 自定义数组元素示例 | |
| object | Object | 否 | | 对象属性示例 | |
| foo | Number | 否 | 1 | 对象属性示例 | +1 |
| bar | String | 否 | ★ | 对象属性示例 | 1-10 |
| placeholder | String | 否 | @title | 占位符示例 | |
===============分割线==================
URL
Method
Request
Response
异构-新建
URL
Method
Request
| 名称 | 类型 | 必选 | 初始值 | 简介 | Mock规则 |
| name | String | 否 | | | |
| kfk_ver | String | 否 | | | |
| dst_node | String | 否 | | 备端节点 | |
| conn_type | String | 否 | | 连接方式 zookepper broker | |
| host | String | 否 | | zookeeper主机 | |
| port | String | 否 | | zookeeper 端口 | |
| broker | String | 否 | | | |
| tabmap | Object | 否 | | | |
| consumer_thread_num | Number | 否 | 2 | | |
| actload_thread_num | Number | 否 | 4 | | |
Response
| 名称 | 类型 | 必选 | 初始值 | 简介 | Mock规则 |
| ret | Number | 否 | 200 | | |
| msg | String | 否 | | | |
| data | Object | 否 | | | |
| message | String | 否 | | | |
| code | Number | 否 | 0 | | |
异构-删除
URL
Method
Request
| 名称 | 类型 | 必选 | 初始值 | 简介 | Mock规则 |
| uuids | Array | 否 | | | |
Response
| 名称 | 类型 | 必选 | 初始值 | 简介 | Mock规则 |
| ret | Number | 否 | 200 | | |
| msg | String | 否 | | | |
| data | Object | 否 | | | |
| message | String | 否 | | | |
| code | Number | 否 | 0 | | |
异构-获取列表
URL
Method
Request
| 名称 | 类型 | 必选 | 初始值 | 简介 | Mock规则 |
| page | Number | 否 | 1 | | |
| limit | Number | 否 | 10 | | |
| search_field | String | 否 | kafka_name | | |
| search_value | String | 否 | | | |
Response
| 名称 | 类型 | 必选 | 初始值 | 简介 | Mock规则 |
| ret | Number | 否 | 200 | | |
| msg | String | 否 | | | |
| data | Object | 否 | | | |
| message | String | 否 | | | |
| code | Number | 否 | 0 | | |
| info_list | Array | 否 | | | |
| name | String | 否 | 测试kafka集群 | | |
| dst_node | String | 否 | 1 | | |
| conn_type | String | 否 | 2.0 | | |
| broker | String | 否 | 192.168.28.90:58080 | | |
| kfk_ver | String | 否 | 3.0 | | |
| uuid | String | 否 | @uuid | | |
| is_biz_admin | Number | 否 | 1 | | |
| can_op | Number | 否 | 1 | | |
| can_up | Number | 否 | 1 | | |
| can_del | Number | 否 | 1 | | |
| broker_id | String | 否 | 1 | | |
异构-查看topic
URL
Method
Request
| 名称 | 类型 | 必选 | 初始值 | 简介 | Mock规则 |
| uuid | String | 否 | | | |
Response
| 名称 | 类型 | 必选 | 初始值 | 简介 | Mock规则 |
| ret | Number | 否 | 200 | | |
| msg | String | 否 | | | |
| data | Object | 否 | | | |
| message | String | 否 | | | |
| code | Number | 否 | 0 | | |
| info_list | Array | 否 | | | |
| topicList | Array | 否 | "topic1","topic2","topic3" | "topic1","topic2","topic3" | |
异构-查看消费者
查看消费者
URL
Method
Request
| 名称 | 类型 | 必选 | 初始值 | 简介 | Mock规则 |
| uuid | String | 否 | | | |
Response
| 名称 | 类型 | 必选 | 初始值 | 简介 | Mock规则 |
| ret | Number | 否 | 200 | | |
| msg | String | 否 | | | |
| data | Object | 否 | | | |
| message | String | 否 | | | |
| code | Number | 否 | 0 | | |
| info_list | Array | 否 | | | |
| consumer | String | 否 | 111 | | |
| topic | String | 否 | 222 | | |
| partition | String | 否 | 333 | | |
| current_offest | String | 否 | 444 | | |
| logend_offset | String | 否 | 5555 | | |
| total | Number | 否 | 10 | | |
异构-消费
消费者新建
URL
Method
Request
| 名称 | 类型 | 必选 | 初始值 | 简介 | Mock规则 |
| topic | String | 否 | | | |
| offset | String | 否 | | | |
| lines | String | 否 | | | |
| show_foward | Number | 否 | | | |
Response
| 名称 | 类型 | 必选 | 初始值 | 简介 | Mock规则 |
| ret | Number | 否 | 200 | | |
| msg | String | 否 | | | |
| data | Object | 否 | | | |
| message | String | 否 | | | |
| code | Number | 否 | 0 | | |
===============分割线==================
URL
Method
Request
Response
异构-消费-新建
URL
Method
Request
| 名称 | 类型 | 必选 | 初始值 | 简介 | Mock规则 |
| name | String | 否 | | | |
| src_db_uuid | String | 否 | | | |
| tgt_type | String | 否 | | | |
| init_offset | Array | 否 | | | |
| topic | String | 否 | | | |
| offset | String | 否 | | | |
| partition | String | 否 | | | |
| modify | String | 否 | false | | |
| topic | String | 否 | | | |
| dst_topic | String | 否 | | | |
| tgt_db_uuid | String | 否 | | oracle 类型时 | |
| init_offset_type | String | 否 | earlist | latest,seek | |
| tabmap | String | 否 | {111:222} | | |
| consumer_thread_num | String | 否 | 2 | | |
| actload_thread_num | String | 否 | 4 | | |
Response
| 名称 | 类型 | 必选 | 初始值 | 简介 | Mock规则 |
| ret | Number | 否 | 200 | | |
| msg | String | 否 | | | |
| data | Object | 否 | | | |
| message | String | 否 | | | |
| code | Number | 否 | 0 | | |
异构-消费-删除
URL
Method
Request
| 名称 | 类型 | 必选 | 初始值 | 简介 | Mock规则 |
| uuid | Array | 否 | | | |
Response
| 名称 | 类型 | 必选 | 初始值 | 简介 | Mock规则 |
| ret | Number | 否 | 200 | | |
| msg | String | 否 | | | |
| data | Object | 否 | | | |
| message | String | 否 | | | |
| code | Number | 否 | 0 | | |
异构-消费-状态
URL
Method
Request
| 名称 | 类型 | 必选 | 初始值 | 简介 | Mock规则 |
| uuids | Array | 否 | | | |
Response
| 名称 | 类型 | 必选 | 初始值 | 简介 | Mock规则 |
| ret | Number | 否 | 200 | | |
| msg | String | 否 | | | |
| data | Object | 否 | | | |
| code | Number | 否 | 0 | | |
| message | String | 否 | | | |
| info_list | Array | 否 | | | |
| uuid | String | 否 | C038DE5A-CDB2-F26D-FA5F-93E3FF266A87 | | |
| run | Object | 否 | | | |
| status | String | 否 | ACTIVE_RULE_DOING | | |
| progress | String | 否 | 80 | | |
异构-消费-操作
stop | resume
URL
Method
Request
| 名称 | 类型 | 必选 | 初始值 | 简介 | Mock规则 |
| uuid | String | 否 | | | |
| operate | String | 否 | | stop | resume |
Response
| 名称 | 类型 | 必选 | 初始值 | 简介 | Mock规则 |
| ret | Number | 否 | 200 | | |
| msg | String | 否 | | | |
| data | Object | 否 | | | |
| message | String | 否 | | | |
| code | Number | 否 | 0 | | |
异构-消费-查看获取规则列表
查看类型
URL
Method
Request
| 名称 | 类型 | 必选 | 初始值 | 简介 | Mock规则 |
| search_field | String | 否 | tgt_type | | |
| limit | Number | 否 | | | |
| page | Number | 否 | | | |
| search_value | String | 否 | | | |
| where_args | Object | 否 | | | |
| uuid | String | 否 | | | |
Response
| 名称 | 类型 | 必选 | 初始值 | 简介 | Mock规则 |
| ret | Number | 否 | 200 | | |
| msg | String | 否 | | | |
| data | Object | 否 | | | |
| message | String | 否 | | | |
| code | Number | 否 | 0 | | |
| info_list | Array | 否 | | | |
| name | String | 否 | @name | | |
| dst_node | String | 否 | 1 | | |
| conn_type | String | 否 | 1 | | |
| uuid | String | 否 | C038DE5A-CDB2-F26D-FA5F-93E3FF266A87 | | |
| tgt_type | String | 否 | kudu | | |
| tarip | String | 否 | 172.168.42.114 | | |
| port | String | 否 | 58080 | | |
| kfk_ver | String | 否 | 2.0 | | |
| dst_topic | String | 否 | | | |
| dst_bootstrap_server | String | 否 | | | |
| bootstrap_server | String | 否 | | | |
| is_biz_admin | Number | 否 | 1 | | |
| can_op | Number | 否 | 1 | | |
| can_up | Number | 否 | 1 | | |
| can_del | Number | 否 | 1 | | |
| topic | String | 否 | | | |
| data_info | Object | 否 | | | |
| src | Object | 否 | | | |
| db_ip | Array | 否 | [192.167.111.111] | | |
| log_read_type | String | 否 | file | | |
| orcl | String | 否 | orcl | | |
| node_name | String | 否 | src1 | | |
| node_ip | String | 否 | 192.167.111.111 | | |
| dst | Object | 否 | | | |
| db_ip | Array | 否 | [192.167.111.112] | | |
| log_read_type | String | 否 | file | | |
| orcl | String | 否 | orcl | | |
| node_name | String | 否 | dst1 | | |
| node_ip | String | 否 | 192.167.111.112 | | |
| dst_broker_server | Array | 否 | | | |
| ip | String | 否 | 199.199.222.222 | | |
| port | String | 否 | 213 | | |
| src_broker_server | Array | 否 | | | |
| ip | String | 否 | 199.199.222.222 | | |
| port | String | 否 | 123 | | |
| src_db_name | String | 否 | 12344 | | |
| tgt_db_name | String | 否 | 5513 | | |
异构-消费-查看
查看消费规则
URL
Method
Request
Response
异构-消费-获取单条规则
查看消费规则
URL
Method
Request
| 名称 | 类型 | 必选 | 初始值 | 简介 | Mock规则 |
| uuid | String | 否 | | | |
Response
| 名称 | 类型 | 必选 | 初始值 | 简介 | Mock规则 |
| ret | Number | 否 | 200 | | |
| msg | String | 否 | | | |
| data | Object | 否 | | | |
| code | Number | 否 | 0 | | |
| message | String | 否 | success | | |
| info_list | Object | 否 | | | |
| name | String | 否 | @name | | |
| tgt_type | String | 否 | kafka | | |
| src_db_uuid | String | 否 | 111 | | |
| tgt_db_uuid | String | 否 | 222 | | |
| topic | String | 否 | 4444,5555 | | |
| dst_topic | String | 否 | 321 | | |
| init_offset_type | String | 否 | seek | | |
| init_offset | Array | 否 | | | |
| topic | String | 否 | 111 | | |
| offset | String | 否 | 222 | | |
| partition | String | 否 | 333 | | |
| actload_thread_num | String | 否 | 4 | | |
| consumer_thread_num | String | 否 | 2 | | |
| tabmap | Array | 否 | | | |
| src_table | String | 否 | 111 | | |
| dst_table | String | 否 | 222 | | |
===============分割线==================
URL
Method
Request
Response
异构-拓扑-新建
URL
Method
Request
| 名称 | 类型 | 必选 | 初始值 | 简介 | Mock规则 |
| graph_name | String | 否 | | | |
| is_parent | String | 否 | | | |
| is_rule | String | 否 | | | |
| consume_rule | Array | 否 | | | |
| id | String | 否 | | | |
| rule_name | String | 否 | | | |
| src_type | String | 否 | | | |
| src_uuid | String | 否 | | | |
| dst_type | String | 否 | | | |
| rule_number | Number | 否 | 1 | | |
| rule_status | String | 否 | | | |
| rule_traffic | String | 否 | | | |
| is_parent | Boolean | 否 | 0 | | |
| is_rule | Boolean | 否 | 0 | | |
| src_name | String | 否 | | | |
| dst_name | String | 否 | | | |
| dst_uuid | String | 否 | | | |
Response
| 名称 | 类型 | 必选 | 初始值 | 简介 | Mock规则 |
| ret | Number | 否 | 200 | | |
| msg | String | 否 | | | |
| data | Object | 否 | | | |
| message | String | 否 | | | |
| code | Number | 否 | 0 | | |
异构-拓扑-添加
URL
Method
Request
| 名称 | 类型 | 必选 | 初始值 | 简介 | Mock规则 |
| graph_uuid | String | 否 | | | |
| rule_number | String | 否 | | | |
| src_type | String | 否 | | oracle,kafka,mysql | |
| rule_uuid | String | 否 | | | |
Response
| 名称 | 类型 | 必选 | 初始值 | 简介 | Mock规则 |
| ret | Number | 否 | 200 | | |
| msg | String | 否 | | | |
| data | Object | 否 | | | |
| message | String | 否 | | | |
| code | Number | 否 | 0 | | |
异构-拓扑-获取列表
URL
Method
Request
| 名称 | 类型 | 必选 | 初始值 | 简介 | Mock规则 |
| page | Number | 否 | 1 | | |
| limit | Number | 否 | 10 | | |
Response
| 名称 | 类型 | 必选 | 初始值 | 简介 | Mock规则 |
| message | String | 否 | success | | |
| ret | Number | 否 | 200 | | |
| msg | String | 否 | | | |
| data | Object | 否 | | | |
| code | Number | 否 | 0 | | |
| info_list | Array | 否 | | | 2 |
| id | Number | 否 | 1 | | |
| graph_name | String | 否 | topo-o2k-kafka-oracle-test2 | | |
| graph_uuid | String | 否 | @uuid | 1BCFCAA3-E3C8-3E28-BDC5-BE36FDC2B5DC-Graph | |
| is_parent | Boolean | 否 | true | | |
| is_rule | Boolean | 否 | 0 | | |
| consume_rule | Array | 否 | | | 4 |
| id | Number | 否 | 11 | | +1 |
| rule_name | String | 否 | o2k-kafka-oracle-test2 | | |
| rule_uuid | String | 否 | 3D7dFcd9-C176-d9ee-4FFB-f22bbd554944 | | |
| src_type | String | 否 | oracle | | |
| src_uuid | String | 否 | 3D7dFcd9-C176-d9ee-4FFB-f22bbd554925 | | |
| dst_type | String | 否 | kafka | | |
| rule_number | Number | 否 | 0 | | +1 |
| rule_status | String | 否 | stop | | |
| rule_traffic | String | 否 | 31455 | | |
| is_parent | Boolean | 否 | false | | |
| is_rule | Boolean | 否 | 0 | | |
| src_name | String | 否 | @name | 源端名字 | |
| dst_name | String | 否 | @name | 备端名字 | |
| dst_uuid | String | 否 | C038DE5A-CDB2-F26D-FA5F-93E3FF266A87 | | |
| can_op | Number | 否 | 1 | | |
| can_up | Number | 否 | 1 | | |
| can_del | Number | 否 | 0 | | |
| is_biz_admin | Number | 否 | 1 | | |
| message | String | 否 | | | |
异构-拓扑-运行拓扑
URL
Method
Request
| 名称 | 类型 | 必选 | 初始值 | 简介 | Mock规则 |
| graphs | Array | 否 | | | |
| graph_uuid | String | 否 | | | |
| rule_uuids | Array | 否 | | | |
| uuid | String | 否 | | | |
| src_type | String | 否 | | oracle,kafka,mysql | |
Response
| 名称 | 类型 | 必选 | 初始值 | 简介 | Mock规则 |
| ret | Number | 否 | 200 | | |
| msg | String | 否 | | | |
| data | Object | 否 | | | |
| message | String | 否 | | | |
| code | Number | 否 | 0 | | |
异构-拓扑-停止拓扑
URL
Method
Request
| 名称 | 类型 | 必选 | 初始值 | 简介 | Mock规则 |
| graphs | Array | 否 | | | |
| graph_uuid | String | 否 | | | |
| rule_uuids | Array | 否 | | | |
| uuid | String | 否 | | | |
| src_type | String | 否 | | oracle,mysql,kafka | |
Response
| 名称 | 类型 | 必选 | 初始值 | 简介 | Mock规则 |
| ret | Number | 否 | 200 | | |
| msg | String | 否 | | | |
| data | Object | 否 | | | |
| message | String | 否 | | | |
| code | Number | 否 | 0 | | |
异构-拓扑-状态
URL
Method
Request
| 名称 | 类型 | 必选 | 初始值 | 简介 | Mock规则 |
| rule_uuids | Array | 否 | | | |
| uuid | String | 否 | | | |
| src_type | String | 否 | | oracle.mysql,kafka | |
Response
| 名称 | 类型 | 必选 | 初始值 | 简介 | Mock规则 |
| ret | Number | 否 | 200 | | |
| msg | String | 否 | | | |
| data | Object | 否 | | | |
| code | Number | 否 | 0 | | |
| message | String | 否 | | | |
| info_list | Array | 否 | | | |
| rule_uuid | String | 否 | | | |
| status | String | 否 | | | |
异构-拓扑-删除拓扑
URL
Method
Request
| 名称 | 类型 | 必选 | 初始值 | 简介 | Mock规则 |
| graph_uuids | Array | 否 | | | |
| graph_uuid | String | 否 | @uuid | | |
| rule_uuids | Array | 否 | | | |
| uuid | String | 否 | @uuid | | |
| is_rule | String | 否 | 1 | | |
| rule_number | String | 否 | 4 | | |
| src_type | String | 否 | oracle | | |
| is_whole | String | 否 | 1 | | |
Response
| 名称 | 类型 | 必选 | 初始值 | 简介 | Mock规则 |
| ret | Number | 否 | 200 | | |
| msg | String | 否 | | | |
| data | Object | 否 | | | |
| message | String | 否 | | | |
| code | Number | 否 | 0 | | |
异构-拓扑-拓扑详情
URL
Method
Request
| 名称 | 类型 | 必选 | 初始值 | 简介 | Mock规则 |
| page | Number | 否 | 1 | | |
| limit | Number | 否 | 10 | | |
| start_time | String | 否 | | | |
| end_time | String | 否 | | | |
| graph_uuid | String | 否 | | | |
Response
| 名称 | 类型 | 必选 | 初始值 | 简介 | Mock规则 |
| ret | Number | 否 | 200 | | |
| msg | String | 否 | | | |
| data | Object | 否 | | | |
| message | String | 否 | | | |
| code | Number | 否 | 0 | | |
| info_list | Array | 否 | | | 2 |
| 2019-10-11 | Array | 否 | | | 2 |
| uuid | String | 否 | 1c7DBA2b-A5AA-F1A6-1587-d5844db5BdAF | | |
| name | String | 否 | @name | | |
| number | Number | 否 | | | 1-100 |
| total | Number | 否 | 1 | | |
===============分割线==================
URL
Method
Request
Response
异构-拓扑图-获取拓扑图
URL
Method
Request
| 名称 | 类型 | 必选 | 初始值 | 简介 | Mock规则 |
| graph_uuid | String | 否 | | | |
Response
| 名称 | 类型 | 必选 | 初始值 | 简介 | Mock规则 |
| ret | Number | 否 | 200 | | |
| msg | String | 否 | | | |
| data | Object | 否 | | | |
| message | String | 否 | | | |
| code | Number | 否 | 0 | | |
| info_list | Array | 否 | | | |
| src | Object | 否 | | | |
| node | Object | 否 | | | |
| name | String | 否 | oracle-kafka-199-266 | | |
| state | String | 否 | ok | | |
| status | String | 否 | node_online | node_online/node_error/node_ignore | |
| type | String | 否 | oracle | | |
| kafka | Object | 否 | | | |
| status | String | 否 | kafka_normal | kafka_normal | |
| srcid | String | 否 | | | |
| traffic | String | 否 | 10004956 | | |
| type | String | 否 | kafka | | |
| name | String | 否 | kafka-oracle | | |
| scntime | String | 否 | 06-25 11:26:19 | | |
| relay | Object | 否 | | | |
| node | Array | 否 | | | |
| name | String | 否 | 300kkkkkkkkkkkkkkkkkkkkkkkkkkkkkkk | | |
| state | String | 否 | ok | | |
| status | String | 否 | db_abnormal | db_abnormal/db_ignore/db_normal | |
| traffic | String | 否 | N/A | | |
| type | String | 否 | kafka | | |
| scntime | String | 否 | N/A | 06-25 11:26:58 | |
| dst | Object | 否 | | | |
| node | Array | 否 | | | 2 |
| name | String | 否 | kafka-oralce-6000123 | | |
| state | String | 否 | ok | | |
| status | String | 否 | node_online | | |
| traffic | String | 否 | 100564 | | |
| type | String | 否 | oracle | | |
| scntime | String | 否 | 06-25 11:26:19 | 06-25 11:26:19 | |
| summary | Object | 否 | | | |
| name | String | 否 | 199-200 | | |
| state | String | 否 | 0 | 1/0 | |
| stage | String | 否 | pause | | |
| uuid | String | 否 | @guid | | |
| status | String | 否 | rect_error | rect_normal | |
| extract | String | 否 | 2019-06-25 11:26:10 | | |