-
Notifications
You must be signed in to change notification settings - Fork 0
/
KAFKA CONNECT API .postman_collection
131 lines (131 loc) · 3.95 KB
/
KAFKA CONNECT API .postman_collection
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
{
"variables": [],
"info": {
"name": "KAFKA CONNECT API ",
"_postman_id": "e5f00bac-3e75-65b5-5479-634351d474a7",
"description": "",
"schema": "https://schema.getpostman.com/json/collection/v2.0.0/collection.json"
},
"item": [
{
"name": "Validation CONFIG",
"request": {
"url": "http://192.168.99.100:28083/connector-plugins/io.confluent.connect.jdbc.JdbcSourceConnector/config/validate/",
"method": "PUT",
"header": [
{
"key": "Content-Type",
"value": "application/json",
"description": ""
}
],
"body": {
"mode": "raw",
"raw": "{\n \"name\":\"quickstart-jdbc-source-foo\",\n \"connector.class\": \"io.confluent.connect.jdbc.JdbcSourceConnector\",\n \"tasks.max\": 1,\n \"connection.url\": \"jdbc:mysql://localhost:3306/connect_test?user=confluent&password=confluent\",\n \"mode\": \"incrementing\",\n \"incrementing.column.name\": \"id\",\n \"timestamp.column.name\": \"modified\",\n \"topic.prefix\": \"quickstart-jdbc-foo\",\n \"poll.interval.ms\": 1000,\n \"table.whitelist\":\"test\"\n}"
},
"description": ""
},
"response": []
},
{
"name": "SHOW LIST PLUGINS",
"request": {
"url": "http://192.168.99.100:28083/connector-plugins/",
"method": "GET",
"header": [
{
"key": "Content-Type",
"value": "application/json",
"description": ""
}
],
"body": {
"mode": "raw",
"raw": "{\n \"connector.class\": \"org.apache.kafka.connect.file.FileStreamSinkConnector\",\n \"tasks.max\": \"1\",\n \"topics\": \"test-topic\"\n}"
},
"description": ""
},
"response": []
},
{
"name": "GET CONNECTOR",
"request": {
"url": "http://192.168.99.100:28083/connectors",
"method": "GET",
"header": [
{
"key": "Content-Type",
"value": "application/json",
"description": ""
}
],
"body": {
"mode": "raw",
"raw": "{\n \"connector.class\": \"org.apache.kafka.connect.file.FileStreamSinkConnector\",\n \"tasks.max\": \"1\",\n \"topics\": \"test-topic\"\n}"
},
"description": ""
},
"response": []
},
{
"name": "GET INFO CONNECTOR",
"request": {
"url": "http://192.168.99.100:28083/connectors/hdfs-sink-connector",
"method": "GET",
"header": [
{
"key": "Content-Type",
"value": "application/json",
"description": ""
}
],
"body": {
"mode": "raw",
"raw": "{\n \"connector.class\": \"org.apache.kafka.connect.file.FileStreamSinkConnector\",\n \"tasks.max\": \"1\",\n \"topics\": \"test-topic\"\n}"
},
"description": ""
},
"response": []
},
{
"name": "Create Config",
"request": {
"url": "http://192.168.99.100:28083/connectors",
"method": "POST",
"header": [
{
"key": "Content-Type",
"value": "application/json",
"description": ""
}
],
"body": {
"mode": "raw",
"raw": "{\n \"name\":\"quickstart-jdbc-source-foo\",\n \"config\":{\n \"connector.class\": \"io.confluent.connect.jdbc.JdbcSourceConnector\",\n \"tasks.max\": 1,\n \"connection.url\": \"jdbc:mysql://localhost:3306/connect_test?user=confluent&password=confluent\",\n \"mode\": \"incrementing\",\n \"incrementing.column.name\": \"id\",\n \"timestamp.column.name\": \"modified\",\n \"topic.prefix\": \"quickstart-jdbc-foo\",\n \"poll.interval.ms\": 1000\n }\n}"
},
"description": ""
},
"response": []
},
{
"name": "GET STATUS CONNECTOR",
"request": {
"url": "http://192.168.99.100:28083/connectors/quickstart-jdbc-source-foo/status",
"method": "GET",
"header": [
{
"key": "Content-Type",
"value": "application/json",
"description": ""
}
],
"body": {
"mode": "raw",
"raw": "{\n \"connector.class\": \"org.apache.kafka.connect.file.FileStreamSinkConnector\",\n \"tasks.max\": \"1\",\n \"topics\": \"test-topic\"\n}"
},
"description": ""
},
"response": []
}
]
}