Skip to content

Commit

Permalink
Deprecate hbase and pulsar connectors (#1005)
Browse files Browse the repository at this point in the history
  • Loading branch information
davidsloan authored Nov 27, 2023
1 parent 8e3fd22 commit 58e5469
Show file tree
Hide file tree
Showing 81 changed files with 2 additions and 6,077 deletions.
5 changes: 2 additions & 3 deletions README.md
Original file line number Diff line number Diff line change
Expand Up @@ -30,7 +30,9 @@ A collection of components to build a real time ingestion pipeline.
The following connectors have been deprecated and are no longer included in future releases:

* Kudu
* HBase
* Hive
* Pulsar

### Connectors

Expand All @@ -46,15 +48,12 @@ The following connectors have been deprecated and are no longer included in futu
| Elastic 6 | Sink | Copy data from Kafka to Elastic Search 6.x w. tcp or http | [Docs](https://docs.lenses.io/connectors/sink/elastic6.html) |
| FTP/HTTP | Source | Copy data from FTP/HTTP to Kafka. | [Docs](https://docs.lenses.io/5.2/connectors/sources/ftpsourceconnector/) |
| Hazelcast | Sink | Copy data from Kafka to Hazelcast. | [Docs](https://docs.lenses.io/connectors/sink/hazelcast.html) |
| HBase | Sink | Copy data from Kafka to HBase. | [Docs](https://docs.lenses.io/connectors/sink/hbase.html) |
| InfluxDb | Sink | Copy data from Kafka to InfluxDb. | [Docs](https://docs.lenses.io/4.0/integrations/connectors/stream-reactor/sinks/influxsinkconnector/) |
| JMS | Source | Copy data from JMS topics/queues to Kafka. | [Docs](https://docs.lenses.io/connectors/source/jms.html) |
| JMS | Sink | Copy data from Kafka to JMS. | [Docs](https://docs.lenses.io/connectors/sink/jms.html) |
| MongoDB | Sink | Copy data from Kafka to MongoDB. | [Docs](https://docs.lenses.io/connectors/sink/mongo.html) |
| MQTT | Source | Copy data from MQTT to Kafka. | [Docs](https://docs.lenses.io/connectors/source/mqtt.html) |
| MQTT | Sink | Copy data from Kafka to MQTT. | [Docs](https://docs.lenses.io/connectors/sink/mqtt.html) |
| Pulsar | Source | Copy data from Pulsar to Kafka. | [Docs](https://docs.lenses.io/connectors/source/pulsar.html) |
| Pulsar | Sink | Copy data from Kafka to Pulsar. | [Docs](https://docs.lenses.io/connectors/sink/pulsar.html) |
| Redis | Sink | Copy data from Kafka to Redis. | [Docs](https://docs.lenses.io/connectors/sink/redis.html) |

## Release Notes
Expand Down
40 changes: 0 additions & 40 deletions build.sbt
Original file line number Diff line number Diff line change
Expand Up @@ -23,12 +23,10 @@ lazy val subProjects: Seq[Project] = Seq(
ftp,
`gcp-storage`,
hazelcast,
hbase,
influxdb,
jms,
mongodb,
mqtt,
pulsar,
redis,
)

Expand Down Expand Up @@ -338,25 +336,6 @@ lazy val mqtt = (project in file("kafka-connect-mqtt"))
.disableParallel()
.enablePlugins(PackPlugin)

lazy val pulsar = (project in file("kafka-connect-pulsar"))
.dependsOn(common)
.settings(
settings ++
Seq(
name := "kafka-connect-pulsar",
description := "Kafka Connect compatible connectors to move data between Kafka and popular data stores",
libraryDependencies ++= baseDeps ++ kafkaConnectPulsarDeps,
publish / skip := true,
packExcludeJars := Seq(
"scala-.*\\.jar",
"zookeeper-.*\\.jar",
),
),
)
.configureAssembly(true)
.configureTests(baseTestDeps)
.enablePlugins(PackPlugin)

lazy val ftp = (project in file("kafka-connect-ftp"))
.dependsOn(common)
.settings(
Expand All @@ -377,25 +356,6 @@ lazy val ftp = (project in file("kafka-connect-ftp"))
.configureIntegrationTests(kafkaConnectFtpTestDeps)
.enablePlugins(PackPlugin)

lazy val hbase = (project in file("kafka-connect-hbase"))
.dependsOn(common)
.settings(
settings ++
Seq(
name := "kafka-connect-hbase",
description := "Kafka Connect compatible connectors to move data between Kafka and popular data stores",
libraryDependencies ++= baseDeps ++ kafkaConnectHbaseDeps,
publish / skip := true,
packExcludeJars := Seq(
"scala-.*\\.jar",
"zookeeper-.*\\.jar",
),
),
)
.configureAssembly(true)
.configureTests(baseTestDeps)
.enablePlugins(PackPlugin)

lazy val mongodb = (project in file("kafka-connect-mongodb"))
.dependsOn(common)
.dependsOn(`test-common` % "test->compile;it->compile;fun->compile")
Expand Down
22 changes: 0 additions & 22 deletions conf/hbase-sink.properties

This file was deleted.

19 changes: 0 additions & 19 deletions kafka-connect-hbase/src/main/resources/hbase-ascii.txt

This file was deleted.

28 changes: 0 additions & 28 deletions kafka-connect-hbase/src/main/resources/logback.xml

This file was deleted.

This file was deleted.

This file was deleted.

This file was deleted.

Loading

0 comments on commit 58e5469

Please sign in to comment.