Commit 314b9de
committed
Initialize pulsar-connectors as standalone repository
Move connectors from pulsar-io/ to top-level directories and set up
standalone Gradle build that consumes Pulsar artifacts as Maven
dependencies.
- Flatten directory structure: pulsar-io/<name>/ -> <name>/
- Add settings.gradle.kts with all connector modules
- Add build.gradle.kts with shared configuration (NAR packaging,
dependency management, test setup)
- Add gradle/libs.versions.toml with connector-specific dependencies
- Add pulsar-dependencies/ platform module pinning Pulsar versions
- Add distribution/io/ for connector NAR distribution packaging
- Update all cross-project references to new flat paths
- Add .gitignore for build artifacts1 parent 3d03f1e commit 314b9de
472 files changed
Lines changed: 1523 additions & 186 deletions
File tree
- aerospike
- src/main
- java/org/apache/pulsar/io/aerospike
- resources
- META-INF/services
- alluxio
- src
- main
- java/org/apache/pulsar/io/alluxio
- sink
- resources/META-INF/services
- test
- java/org/apache/pulsar/io/alluxio/sink
- resources
- aws
- src/main
- java/org/apache/pulsar/io/aws
- resources
- azure-data-explorer
- src
- main
- java/org/apache/pulsar/io/azuredataexplorer
- resources/META-INF/services
- test
- java/org/apache/pulsar/io/azuredataexplorer
- resources
- canal
- src/main
- java/org/apache/pulsar/io/canal
- resources
- META-INF/services
- cassandra
- src/main
- java/org/apache/pulsar/io/cassandra
- resources/META-INF/services
- debezium
- core
- src
- main/java/org/apache/pulsar/io/debezium
- test/java/org/apache/pulsar/io/debezium
- mongodb
- src/main
- java/org/apache/pulsar/io/debezium/mongodb
- resources
- META-INF/services
- mssql
- src/main
- java/org/apache/pulsar/io/debezium/mssql
- resources
- META-INF/services
- mysql
- src/main
- java/org/apache/pulsar/io/debezium/mysql
- resources
- META-INF/services
- oracle
- src/main
- java/org/apache/pulsar/io/debezium/oracle
- resources
- META-INF/services
- postgres
- src/main
- java/org/apache/pulsar/io/debezium/postgres
- resources
- META-INF/services
- distribution/io
- docs
- src/main
- java/org/apache/pulsar/io/docs
- resources
- dynamodb
- src
- main
- java/org/apache/pulsar/io/dynamodb
- resources/META-INF/services
- test
- java/org/apache/pulsar/io/dynamodb
- resources
- elastic-search
- src
- main
- java/org/apache/pulsar/io/elasticsearch
- client
- elastic
- opensearch
- resources/META-INF/services
- test
- java/org/apache/pulsar/io/elasticsearch
- client
- data
- opensearch
- testcontainers
- v7
- v8
- resources
- ssl
- file
- src
- main
- java/org/apache/pulsar/io/file
- utils
- resources/META-INF/services
- test
- java/org/apache/pulsar/io/file
- utils
- resources
- org/apache/pulsar/io/file
- gradle
- wrapper
- hbase
- src
- main
- java/org/apache/pulsar/io/hbase
- sink
- resources/META-INF/services
- test
- java/org/apache/pulsar/io/hbase
- sink
- resources
- hbase
- hdfs3
- src
- main
- java/org/apache/pulsar/io/hdfs3
- sink
- seq
- text
- resources
- META-INF/services
- test
- java/org/apache/pulsar/io/hdfs3/sink
- seq
- text
- resources
- hadoop
- http
- src
- main
- java/org/apache/pulsar/io/http
- resources/META-INF/services
- test/java/org/apache/pulsar/io/http
- influxdb
- src
- main
- java/org/apache/pulsar/io/influxdb
- v1
- v2
- resources/META-INF/services
- test
- java/org/apache/pulsar/io/influxdb
- v1
- v2
- resources
- jdbc
- clickhouse
- src/main
- java/org/apache/pulsar/io/jdbc
- resources/META-INF/services
- core
- src
- main/java/org/apache/pulsar/io/jdbc
- test/java/org/apache/pulsar/io/jdbc
- mariadb
- src/main
- java/org/apache/pulsar/io/jdbc
- resources/META-INF/services
- openmldb
- src/main
- java/org/apache/pulsar/io/jdbc
- resources/META-INF/services
- postgres
- src
- main
- java/org/apache/pulsar/io/jdbc
- resources/META-INF/services
- test/java/org/apache/pulsar/io/jdbc
- sqlite
- src
- main
- java/org/apache/pulsar/io/jdbc
- resources/META-INF/services
- test/java/org/apache/pulsar/io/jdbc
- kafka-connect-adaptor-nar
- src/main/resources/META-INF/services
- kafka-connect-adaptor
- src
- main/java/org/apache/pulsar/io/kafka/connect
- schema
- test/java/org/apache/pulsar/io/kafka/connect
- kafka
- src
- main
- java/org/apache/pulsar/io/kafka
- resources
- META-INF/services
- test
- java/org/apache/pulsar/io/kafka
- sink
- source
- resources
- kinesis-kpl-shaded
- kinesis
- src
- main
- fb
- java/org/apache/pulsar/io/kinesis
- fbs
- json
- resources/META-INF/services
- test/java/org/apache/pulsar/io/kinesis
- json
- mongo
- src
- main
- java/org/apache/pulsar/io/mongodb
- resources/META-INF/services
- test
- java/org/apache/pulsar/io/mongodb
- resources
- netty
- src
- main
- java
- org/apache/pulsar/io/netty
- http
- server
- tcp
- udp
- resources
- META-INF/services
- test
- java/org/apache/pulsar/io/netty
- http
- server
- tcp
- udp
- resources
- nsq
- src
- main
- java/org/apache/pulsar/io/nsq
- resources/META-INF/services
- test
- java/org/apache/pulsar/io/nsq
- resources
- pulsar-dependencies
- pulsar-io/docs
- rabbitmq
- src
- main
- java/org/apache/pulsar/io/rabbitmq
- resources/META-INF/services
- test
- java/org/apache/pulsar/io/rabbitmq
- sink
- source
- resources
- redis
- src
- main
- java/org/apache/pulsar/io/redis
- sink
- resources/META-INF/services
- test
- java/org/apache/pulsar/io/redis
- sink
- resources
- solr
- src
- main
- java/org/apache/pulsar/io/solr
- resources
- META-INF/services
- test
- java/org/apache/pulsar/io/solr
- resources
Some content is hidden
Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
| 1 | + | |
| 2 | + | |
| 3 | + | |
| 4 | + | |
| 5 | + | |
| 6 | + | |
| 7 | + | |
| 8 | + | |
| 9 | + | |
| 10 | + | |
| 11 | + | |
| 12 | + | |
| 13 | + | |
| 14 | + | |
Lines changed: 1 addition & 1 deletion
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
21 | 21 | | |
22 | 22 | | |
23 | 23 | | |
24 | | - | |
| 24 | + | |
25 | 25 | | |
26 | 26 | | |
27 | 27 | | |
| |||
File renamed without changes.
Lines changed: 2 additions & 2 deletions
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
21 | 21 | | |
22 | 22 | | |
23 | 23 | | |
24 | | - | |
| 24 | + | |
25 | 25 | | |
26 | 26 | | |
27 | 27 | | |
28 | 28 | | |
29 | | - | |
| 29 | + | |
30 | 30 | | |
31 | 31 | | |
0 commit comments