Skip to content

Commit 02e7534

Browse files
chdaskchdask
authored
Merge pull request #55 from Landoop/supported-connectors-changes
Supported Connectors: adding pulsar support, fixing ftp class, changing doc links
2 parents 614dfff + 9599aca commit 02e7534

File tree

2 files changed

+76
-34
lines changed

2 files changed

+76
-34
lines changed

‎src/assets/icons/pulsar-logo.png‎

5.9 KB
Loading

‎src/supported-connectors.js‎

Lines changed: 76 additions & 34 deletions
Original file line numberDiff line numberDiff line change
@@ -18,7 +18,7 @@ var supportedConnectorsTemplates = [
1818
uiEnabled: true,
1919
color: "#30007b",
2020
class: "com.datamountaineer.streamreactor.connect.yahoo.source.YahooSourceConnector",
21-
docs: "//docs.datamountaineer.com/en/latest/yahoo.html",
21+
docs: "//lenses.stream/connectors/source/yahoo.html",
2222
author:'Landoop - Stream Reactor'
2323
},
2424
{
@@ -38,8 +38,17 @@ var supportedConnectorsTemplates = [
3838
type: "Source",
3939
uiEnabled: true,
4040
color: "#b1b1b1",
41-
class: "com.datamountaineer.streamreactor.connect.ftp.FtpSourceConnector",
42-
docs: "//docs.datamountaineer.com/en/latest/ftp-source.html",
41+
class: "com.datamountaineer.streamreactor.connect.ftp.source.FtpSourceConnector",
42+
docs: "//lenses.stream/connectors/source/ftp.html",
43+
author:'Landoop - Stream Reactor'
44+
},
45+
{
46+
name: "SQL",
47+
icon: "database.png",
48+
type: "Source",
49+
uiEnabled: true,
50+
color: "#b1b1b1",
51+
class: "com.landoop.connect.SQL",
4352
author:'Landoop - Stream Reactor'
4453
},
4554
{
@@ -50,7 +59,7 @@ var supportedConnectorsTemplates = [
5059
uiEnabled: true,
5160
color: "#b1b1b1",
5261
class: "com.datamountaineer.streamreactor.connect.blockchain.source.BlockchainSourceConnector",
53-
docs: "//docs.datamountaineer.com/en/latest/blockchain.html",
62+
docs: "//lenses.stream/connectors/source/blockchain.html",
5463
author:'Landoop - Stream Reactor'
5564
},
5665
{
@@ -71,7 +80,18 @@ var supportedConnectorsTemplates = [
7180
type: "Source",
7281
color: "",
7382
class: "com.datamountaineer.streamreactor.connect.cassandra.source.CassandraSourceConnector",
74-
docs: "//docs.datamountaineer.com/en/latest/cassandra-source.html",
83+
docs: "//lenses.stream/connectors/source/cassandra.html",
84+
author:'Landoop - Stream Reactor'
85+
},
86+
{
87+
name: "CassandraCDC",
88+
icon: "cassandra.jpg",
89+
description: "Extract Cassandra data using the CQL driver into Kafka",
90+
uiEnabled: true,
91+
type: "Source",
92+
color: "",
93+
class: "com.datamountaineer.streamreactor.connect.cassandra.cdc.CassandraCdcSourceConnector",
94+
docs: "//lenses.stream/connectors/source/cassandra-cdc.html",
7595
author:'Landoop - Stream Reactor'
7696
},
7797
{
@@ -82,7 +102,7 @@ var supportedConnectorsTemplates = [
82102
uiEnabled: true,
83103
color: "#a65674",
84104
class: "com.datamountaineer.streamreactor.connect.bloomberg.BloombergSourceConnector",
85-
docs: "//docs.datamountaineer.com/en/latest/bloomberg.html",
105+
docs: "//lenses.stream/connectors/source/bloomberg.html",
86106
author:'Landoop - Stream Reactor'
87107
},
88108
{
@@ -93,7 +113,7 @@ var supportedConnectorsTemplates = [
93113
uiEnabled: true,
94114
color: "pink",
95115
class: "com.datamountaineer.streamreactor.connect.jms.source.JMSSourceConnector",
96-
docs: "//docs.datamountaineer.com/en/latest/jms-source.html",
116+
docs: "//lenses.stream/connectors/source/jms.html",
97117
author:'Landoop - Stream Reactor'
98118
},
99119
{
@@ -104,7 +124,7 @@ var supportedConnectorsTemplates = [
104124
uiEnabled: true,
105125
color: "#5B346C",
106126
class: "com.datamountaineer.streamreactor.connect.mqtt.source.MqttSourceConnector",
107-
docs: "//docs.datamountaineer.com/en/latest/mqtt.html",
127+
docs: "//lenses.stream/connectors/source/mqtt.html",
108128
author:'Landoop - Stream Reactor'
109129
},
110130
{
@@ -115,7 +135,7 @@ var supportedConnectorsTemplates = [
115135
color: "#4A3A41",
116136
uiEnabled: true,
117137
class: "com.datamountaineer.streamreactor.connect.rethink.source.ReThinkSourceConnector",
118-
docs: "//docs.datamountaineer.com/en/latest/rethink-source.html",
138+
docs: "//lenses.stream/connectors/source/rethink.html",
119139
author:'Landoop - Stream Reactor'
120140
},
121141
{
@@ -126,7 +146,18 @@ var supportedConnectorsTemplates = [
126146
color: "#3A3A3A",
127147
uiEnabled: true,
128148
class: "com.datamountaineer.streamreactor.connect.coap.source.CoapSourceConnector",
129-
docs: "//docs.datamountaineer.com/en/latest/coap-source.html",
149+
docs: "//lenses.stream/connectors/source/coap.html",
150+
author:'Landoop - Stream Reactor'
151+
},
152+
{
153+
name: "Pulsar",
154+
type: "Source",
155+
icon: "pulsar-logo.png",
156+
description: "Get data from Pulsar into Kafka",
157+
color: "#3A3A3A",
158+
uiEnabled: true,
159+
class: "com.datamountaineer.streamreactor.connect.pulsar.source.PulsarSourceConnector",
160+
docs: "//lenses.stream/connectors/source/pulsar.html",
130161
author:'Landoop - Stream Reactor'
131162
},
132163
{
@@ -168,7 +199,7 @@ var supportedConnectorsTemplates = [
168199
type: "Sink",
169200
uiEnabled: true,
170201
class: "com.datamountaineer.streamreactor.connect.elastic.ElasticSinkConnector",
171-
docs: "//docs.datamountaineer.com/en/latest/elastic.html",
202+
docs: "//lenses.stream/connectors/sink/elastic.html",
172203
author:'Landoop - Stream Reactor'
173204
},
174205
{
@@ -179,7 +210,7 @@ var supportedConnectorsTemplates = [
179210
type: "Sink",
180211
uiEnabled: true,
181212
class: "com.datamountaineer.streamreactor.connect.elastic5.ElasticSinkConnector",
182-
docs: "//docs.datamountaineer.com/en/latest/elastic5.html",
213+
docs: "//lenses.stream/connectors/sink/elastic5.html",
183214
author:'Landoop - Stream Reactor'
184215
},
185216
{
@@ -190,7 +221,7 @@ var supportedConnectorsTemplates = [
190221
type: "Sink",
191222
uiEnabled: true,
192223
class: "com.datamountaineer.streamreactor.connect.mqtt.sink.MqttSinkConnector",
193-
docs: "//docs.datamountaineer.com/en/latest/mqtt-sink.html",
224+
docs: "//lenses.stream/connectors/sink/mqtt.html",
194225
author:'Landoop - Stream Reactor'
195226
},
196227
{
@@ -201,7 +232,7 @@ var supportedConnectorsTemplates = [
201232
type: "Sink",
202233
color: "#1a9f85",
203234
class: "com.datamountaineer.streamreactor.connect.cassandra.sink.CassandraSinkConnector",
204-
docs: "//docs.datamountaineer.com/en/latest/cassandra-sink.html",
235+
docs: "//lenses.stream/connectors/sink/cassandra.html",
205236
author:'Landoop - Stream Reactor'
206237
},
207238
{
@@ -212,7 +243,7 @@ var supportedConnectorsTemplates = [
212243
type: "Sink",
213244
color: "#0090BA",
214245
class: "com.datamountaineer.streamreactor.connect.influx.InfluxSinkConnector",
215-
docs: "//docs.datamountaineer.com/en/latest/influx.html",
246+
docs: "//lenses.stream/connectors/sink/influx.html",
216247
author:'Landoop - Stream Reactor'
217248
},
218249
{
@@ -223,7 +254,7 @@ var supportedConnectorsTemplates = [
223254
color: "#609959",
224255
uiEnabled: true,
225256
class: "com.datamountaineer.streamreactor.connect.mongodb.sink.MongoSinkConnector",
226-
docs: "//docs.datamountaineer.com/en/latest/mongo-sink.html",
257+
docs: "//lenses.stream/connectors/sink/mongo.html",
227258
author:'Landoop - Stream Reactor'
228259
},
229260
{
@@ -234,7 +265,18 @@ var supportedConnectorsTemplates = [
234265
uiEnabled: true,
235266
color: "#002A36",
236267
class: "com.datamountaineer.streamreactor.connect.hazelcast.sink.HazelCastSinkConnector",
237-
docs: "//docs.datamountaineer.com/en/latest/hazelcast.html",
268+
docs: "//lenses.stream/connectors/sink/hazelcast.html",
269+
author:'Landoop - Stream Reactor'
270+
},
271+
{
272+
name: "Pulsar",
273+
type: "Sink",
274+
icon: "pulsar-logo.png",
275+
description: "Write Kafka data into Pulsar",
276+
color: "#3A3A3A",
277+
uiEnabled: true,
278+
class: "com.datamountaineer.streamreactor.connect.pulsar.sink.PulsarSinkConnector",
279+
docs: "//lenses.stream/connectors/sink/pulsar.html",
238280
author:'Landoop - Stream Reactor'
239281
},
240282
{
@@ -265,7 +307,7 @@ var supportedConnectorsTemplates = [
265307
color: "#3A3A3A",
266308
uiEnabled: true,
267309
class: "com.datamountaineer.streamreactor.connect.azure.documentdb.sink.DocumentDbSinkConnector",
268-
docs: "//docs.datamountaineer.com/en/latest/azuredocdb-sink.html",
310+
docs: "//lenses.stream/connectors/sink/azuredocdb.html",
269311
author:'Landoop - Stream Reactor'
270312
},
271313
{
@@ -276,7 +318,7 @@ var supportedConnectorsTemplates = [
276318
uiEnabled: true,
277319
color: "#D8291F",
278320
class: "com.datamountaineer.streamreactor.connect.redis.sink.RedisSinkConnector",
279-
docs: "//docs.datamountaineer.com/en/latest/redis.html",
321+
docs: "//lenses.stream/connectors/sink/redis.html",
280322
author:'Landoop - Stream Reactor'
281323
},
282324
{
@@ -287,7 +329,7 @@ var supportedConnectorsTemplates = [
287329
uiEnabled: true,
288330
color: "#549998",
289331
class: "com.datamountaineer.streamreactor.connect.kudu.sink.KuduSinkConnector",
290-
docs: "//docs.datamountaineer.com/en/latest/kudu.html",
332+
docs: "//lenses.stream/connectors/sink/kudu.html",
291333
author:'Landoop - Stream Reactor'
292334
},
293335
{
@@ -298,7 +340,7 @@ var supportedConnectorsTemplates = [
298340
uiEnabled: true,
299341
color: "#879171",
300342
class: "com.datamountaineer.streamreactor.connect.jms.sink.JMSSinkConnector",
301-
docs: "//docs.datamountaineer.com/en/latest/jms.html",
343+
docs: "//lenses.stream/connectors/sink/jms.html",
302344
author:'Landoop - Stream Reactor'
303345
},
304346
{
@@ -318,7 +360,7 @@ var supportedConnectorsTemplates = [
318360
description: 'A sink connector to write Kafka data into VoltDB',
319361
color: "#e8371b",
320362
class: "com.datamountaineer.streamreactor.connect.voltdb.VoltSinkConnector",
321-
docs: "//docs.datamountaineer.com/en/latest/voltdb.html",
363+
docs: "//lenses.stream/connectors/sink/voltdb.html",
322364
author:'Landoop - Stream Reactor'
323365
},
324366
{
@@ -339,7 +381,7 @@ var supportedConnectorsTemplates = [
339381
color: "#3A3A3A",
340382
uiEnabled: true,
341383
class: "com.datamountaineer.streamreactor.connect.coap.sink.CoapSinkConnector",
342-
docs: "//docs.datamountaineer.com/en/latest/coap-sink.html",
384+
docs: "//lenses.stream/connectors/sink/coap.html",
343385
author:'Landoop - Stream Reactor'
344386
},
345387
{
@@ -350,7 +392,7 @@ var supportedConnectorsTemplates = [
350392
uiEnabled: true,
351393
color: "#6d1c7c",
352394
class: "com.datamountaineer.streamreactor.connect.hbase.HbaseSinkConnector",
353-
docs: "//docs.datamountaineer.com/en/latest/hbase.html",
395+
docs: "//lenses.stream/connectors/sink/hbase.html",
354396
author:'Landoop - Stream Reactor'
355397
},
356398
{
@@ -361,7 +403,7 @@ var supportedConnectorsTemplates = [
361403
uiEnabled: true,
362404
color: "#4A3A41",
363405
class: "com.datamountaineer.streamreactor.connect.rethink.sink.ReThinkSinkConnector",
364-
docs: "//docs.datamountaineer.com/en/latest/rethink.html",
406+
docs: "//lenses.stream/connectors/sink/rethink.html",
365407
author:'Landoop - Stream Reactor'
366408
},
367409
{
@@ -393,13 +435,13 @@ var supportedConnectorsTemplates = [
393435
class: "com.eneco.trading.kafka.connect.twitter.TwitterSinkConnector",
394436
docs: "https://github.com/Eneco/kafka-connect-twitter",
395437
author:'Eneco'
396-
}
397-
];
438+
}];
398439

399-
var defaultConnectorInfo = {
400-
name: "unknown",
401-
type: "unknown",
402-
color: "",
403-
class: "",
404-
docs: "unknown.html"
405-
};
440+
var defaultConnectorInfo = {
441+
name: "unknown",
442+
type: "unknown",
443+
color: "",
444+
class: "",
445+
docs: "unknown.html"
446+
};
447+

0 commit comments

Comments
 (0)