# 异构管理

kafka监控 kafka消费

# 示例接口

示例接口描述

# URL

//example/1571888297732

# Method

GET

# 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

//example

# Method

GET

# Request

名称 类型 必选 初始值 简介 Mock规则

# Response

名称 类型 必选 初始值 简介 Mock规则

# 异构-新建

# URL

//hetero/rule

# Method

POST

# 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

//hetero

# Method

DELETE

# Request

名称 类型 必选 初始值 简介 Mock规则
uuids Array 否

# Response

名称 类型 必选 初始值 简介 Mock规则
ret Number 否 200
msg String 否
data Object 否
  message String 否
  code Number 否 0

# 异构-获取列表

# URL

//hetero/rule

# Method

GET

# 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

//hetero/topic

# Method

GET

# 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

//hetero/view_consumer

# Method

POST

# 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

//hetero/consumer

# Method

POST

# 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

//example/com

# Method

GET

# Request

名称 类型 必选 初始值 简介 Mock规则

# Response

名称 类型 必选 初始值 简介 Mock规则

# 异构-消费-新建

# URL

//hetero/consumer/rule

# Method

POST

# 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

//hetero/consumer/rule

# Method

DELETE

# Request

名称 类型 必选 初始值 简介 Mock规则
uuid Array 否

# Response

名称 类型 必选 初始值 简介 Mock规则
ret Number 否 200
msg String 否
data Object 否
  message String 否
  code Number 否 0

# 异构-消费-状态

# URL

//hetero/consumer/status

# Method

GET

# 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

//hetero/consumer/operate

# Method

POST

# Request

名称 类型 必选 初始值 简介 Mock规则
uuid String 否
operate String 否 stop resume

# Response

名称 类型 必选 初始值 简介 Mock规则
ret Number 否 200
msg String 否
data Object 否
  message String 否
  code Number 否 0

# 异构-消费-查看获取规则列表

查看类型

# URL

//hetero/consumer/viewtype

# Method

GET

# 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

//hetero/consumer/rule

# Method

PUT

# Request

名称 类型 必选 初始值 简介 Mock规则

# Response

名称 类型 必选 初始值 简介 Mock规则

# 异构-消费-获取单条规则

查看消费规则

# URL

//hetero/consumer/rule

# Method

GET

# 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

/kafkaGraph

# Method

GET

# Request

名称 类型 必选 初始值 简介 Mock规则

# Response

名称 类型 必选 初始值 简介 Mock规则

# 异构-拓扑-新建

# URL

//hetero/graph

# Method

POST

# 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

//hetero/graph/add

# Method

POST

# 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

//hetero/graph/list

# Method

GET

# 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

//hetero/graph/run

# Method

POST

# 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

//hetero/graph/stop

# Method

POST

# 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

//hetero/graph/status

# Method

POST

# 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

//hetero/graph

# Method

DELETE

# 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

//hetero/graph/detail

# Method

GET

# 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

//example/

# Method

GET

# Request

名称 类型 必选 初始值 简介 Mock规则

# Response

名称 类型 必选 初始值 简介 Mock规则

# 异构-拓扑图-获取拓扑图

# URL

//hetero/graph/graph

# Method

GET

# 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
Last Updated: 5/13/2020, 3:56:32 AM