This is an automated email from the ASF dual-hosted git repository.
acosentino pushed a commit to branch fixed-docs
in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git
commit f6337e5a0f00bedde0e9100ec02577c73877284f
Author: Andrea Cosentino <anco...@gmail.com>
AuthorDate: Wed May 27 14:57:38 2020 +0200
Fixed the examples by using the correct classes
---
config/CamelSinkConnector.properties | 2 +-
config/CamelSourceConnector.properties | 2 +-
examples/CamelAWSKinesisSourceConnector.properties | 2 +-
examples/CamelAWSS3SourceConnector.properties | 2 +-
examples/CamelAWSSNSSinkConnector.properties | 2 +-
examples/CamelAWSSQSSinkConnector.properties | 2 +-
examples/CamelAWSSQSSourceConnector.properties | 2 +-
examples/CamelCassandraQLSinkConnector.properties | 2 +-
examples/CamelCassandraQLSourceConnector.properties | 2 +-
examples/CamelElasticSearchSinkConnector.properties | 2 +-
examples/CamelFileSinkConnector.properties | 2 +-
examples/CamelHttpSinkConnector.properties | 2 +-
examples/CamelJmsSinkConnector.properties | 4 ++--
examples/CamelJmsSourceConnector.properties | 2 +-
examples/CamelSlackSinkConnector.properties | 2 +-
examples/CamelTelegramSourceConnector.properties | 2 +-
16 files changed, 17 insertions(+), 17 deletions(-)
diff --git a/config/CamelSinkConnector.properties
b/config/CamelSinkConnector.properties
index 5b8bdac..784fa87 100644
--- a/config/CamelSinkConnector.properties
+++ b/config/CamelSinkConnector.properties
@@ -18,7 +18,7 @@
name=CamelSinkConnector
topics=mytopic
tasks.max=1
-connector.class=org.apache.camel.kafkaconnector.CamelSinkConnector
+connector.class=org.apache.camel.kafkaconnector.log.CamelLogSinkConnector
key.converter=org.apache.kafka.connect.storage.StringConverter
value.converter=org.apache.kafka.connect.storage.StringConverter
diff --git a/config/CamelSourceConnector.properties
b/config/CamelSourceConnector.properties
index 3d88460..7dd82ee 100644
--- a/config/CamelSourceConnector.properties
+++ b/config/CamelSourceConnector.properties
@@ -17,7 +17,7 @@
name=CamelSourceConnector
tasks.max=1
-connector.class=org.apache.camel.kafkaconnector.CamelSourceConnector
+connector.class=org.apache.camel.kafkaconnector.timer.CamelTimerSourceConnector
key.converter=org.apache.kafka.connect.storage.StringConverter
value.converter=org.apache.kafka.connect.storage.StringConverter
diff --git a/examples/CamelAWSKinesisSourceConnector.properties
b/examples/CamelAWSKinesisSourceConnector.properties
index f8dcd77..b17de86 100644
--- a/examples/CamelAWSKinesisSourceConnector.properties
+++ b/examples/CamelAWSKinesisSourceConnector.properties
@@ -13,7 +13,7 @@
# See the License for the specific language governing permissions and
# limitations under the License.
name=CamelAWSKinesisSourceConnector
-connector.class=org.apache.camel.kafkaconnector.CamelSourceConnector
+connector.class=org.apache.camel.kafkaconnector.awskinesis.CamelAwskinesisSourceConnector
key.converter=org.apache.kafka.connect.storage.StringConverter
value.converter=org.apache.kafka.connect.storage.StringConverter
diff --git a/examples/CamelAWSS3SourceConnector.properties
b/examples/CamelAWSS3SourceConnector.properties
index fc4be7f..52be60f 100644
--- a/examples/CamelAWSS3SourceConnector.properties
+++ b/examples/CamelAWSS3SourceConnector.properties
@@ -16,7 +16,7 @@
#
name=CamelAWSS3SourceConnector
-connector.class=org.apache.camel.kafkaconnector.CamelSourceConnector
+connector.class=org.apache.camel.kafkaconnector.awss3.CamelAwss3SourceConnector
key.converter=org.apache.kafka.connect.storage.StringConverter
value.converter=org.apache.camel.kafkaconnector.converters.S3ObjectConverter
#transforms=S3ObjectTransformer
diff --git a/examples/CamelAWSSNSSinkConnector.properties
b/examples/CamelAWSSNSSinkConnector.properties
index b20245b..9aa526c 100644
--- a/examples/CamelAWSSNSSinkConnector.properties
+++ b/examples/CamelAWSSNSSinkConnector.properties
@@ -18,7 +18,7 @@
name=CamelAWSSNSSinkConnector
topics=mytopic
tasks.max=1
-connector.class=org.apache.camel.kafkaconnector.CamelSinkConnector
+connector.class=org.apache.camel.kafkaconnector.awssns.CamelAwssnsSinkConnector
key.converter=org.apache.kafka.connect.storage.StringConverter
value.converter=org.apache.kafka.connect.storage.StringConverter
diff --git a/examples/CamelAWSSQSSinkConnector.properties
b/examples/CamelAWSSQSSinkConnector.properties
index 500008d..a3aca69 100644
--- a/examples/CamelAWSSQSSinkConnector.properties
+++ b/examples/CamelAWSSQSSinkConnector.properties
@@ -18,7 +18,7 @@
name=CamelAWSSQSSinkConnector
topics=mytopic
tasks.max=1
-connector.class=org.apache.camel.kafkaconnector.CamelSinkConnector
+connector.class=org.apache.camel.kafkaconnector.awssqs.CamelAwssqsSinkConnector
key.converter=org.apache.kafka.connect.storage.StringConverter
value.converter=org.apache.kafka.connect.storage.StringConverter
diff --git a/examples/CamelAWSSQSSourceConnector.properties
b/examples/CamelAWSSQSSourceConnector.properties
index 5d85a40..0147187 100644
--- a/examples/CamelAWSSQSSourceConnector.properties
+++ b/examples/CamelAWSSQSSourceConnector.properties
@@ -16,7 +16,7 @@
#
name=CamelAWSSQSSourceConnector
-connector.class=org.apache.camel.kafkaconnector.CamelSourceConnector
+connector.class=org.apache.camel.kafkaconnector.awssqs.CamelAwssqsSourceConnector
key.converter=org.apache.kafka.connect.storage.StringConverter
value.converter=org.apache.kafka.connect.storage.StringConverter
diff --git a/examples/CamelCassandraQLSinkConnector.properties
b/examples/CamelCassandraQLSinkConnector.properties
index e030f95..8917bdd 100644
--- a/examples/CamelCassandraQLSinkConnector.properties
+++ b/examples/CamelCassandraQLSinkConnector.properties
@@ -18,7 +18,7 @@
name=CamelCassandraQLSinkConnector
topics=mytopic
tasks.max=1
-connector.class=org.apache.camel.kafkaconnector.CamelSinkConnector
+connector.class=org.apache.camel.kafkaconnector.cql.CamelCqlSinkConnector
key.converter=org.apache.kafka.connect.storage.StringConverter
value.converter=org.apache.kafka.connect.storage.StringConverter
diff --git a/examples/CamelCassandraQLSourceConnector.properties
b/examples/CamelCassandraQLSourceConnector.properties
index ea60f4c..4795eb9 100644
--- a/examples/CamelCassandraQLSourceConnector.properties
+++ b/examples/CamelCassandraQLSourceConnector.properties
@@ -16,7 +16,7 @@
#
name=CamelCassandraQLSourceConnector
-connector.class=org.apache.camel.kafkaconnector.CamelSourceConnector
+connector.class=org.apache.camel.kafkaconnector.cql.CamelCqlSourceConnector
key.converter=org.apache.kafka.connect.storage.StringConverter
value.converter=org.apache.kafka.connect.storage.StringConverter
diff --git a/examples/CamelElasticSearchSinkConnector.properties
b/examples/CamelElasticSearchSinkConnector.properties
index a6679ee..02e966f 100644
--- a/examples/CamelElasticSearchSinkConnector.properties
+++ b/examples/CamelElasticSearchSinkConnector.properties
@@ -18,7 +18,7 @@
name=CamelElasticSearchSinkConnector
topics=mytopic
tasks.max=1
-connector.class=org.apache.camel.kafkaconnector.CamelSinkConnector
+connector.class=org.apache.camel.kafkaconnector.elasticsearchrest.CamelElasticsearchrestSinkConnector
key.converter=org.apache.kafka.connect.storage.StringConverter
value.converter=org.apache.kafka.connect.storage.StringConverter
diff --git a/examples/CamelFileSinkConnector.properties
b/examples/CamelFileSinkConnector.properties
index bb97540..ce11259 100644
--- a/examples/CamelFileSinkConnector.properties
+++ b/examples/CamelFileSinkConnector.properties
@@ -18,7 +18,7 @@
name=CamelFileSinkConnector
topics=mytopic
tasks.max=1
-connector.class=org.apache.camel.kafkaconnector.CamelSinkConnector
+connector.class=org.apache.camel.kafkaconnector.file.CamelFileSinkConnector
key.converter=org.apache.kafka.connect.storage.StringConverter
value.converter=org.apache.kafka.connect.storage.StringConverter
diff --git a/examples/CamelHttpSinkConnector.properties
b/examples/CamelHttpSinkConnector.properties
index 384da26..6e12b83 100644
--- a/examples/CamelHttpSinkConnector.properties
+++ b/examples/CamelHttpSinkConnector.properties
@@ -18,7 +18,7 @@
name=CamelHttpSinkConnector
topics=mytopic
tasks.max=1
-connector.class=org.apache.camel.kafkaconnector.CamelSinkConnector
+connector.class=org.apache.camel.kafkaconnector.http.CamelHttpSinkConnector
key.converter=org.apache.kafka.connect.storage.StringConverter
value.converter=org.apache.kafka.connect.storage.StringConverter
diff --git a/examples/CamelJmsSinkConnector.properties
b/examples/CamelJmsSinkConnector.properties
index 8e0b917..1898b5b 100644
--- a/examples/CamelJmsSinkConnector.properties
+++ b/examples/CamelJmsSinkConnector.properties
@@ -18,7 +18,7 @@
name=CamelJmsSinkConnector
topics=mytopic
tasks.max=1
-connector.class=org.apache.camel.kafkaconnector.CamelSinkConnector
+connector.class=org.apache.camel.kafkaconnector.sjms2.CamelSjms2SinkConnector
key.converter=org.apache.kafka.connect.storage.StringConverter
value.converter=org.apache.kafka.connect.storage.StringConverter
@@ -29,4 +29,4 @@
camel.component.sjms2.connection-factory.brokerURL=tcp://localhost:61616
# If using AMQP via QPid JMS:
#
camel.component.sjms2.connection-factory=#class:org.apache.qpid.jms.JmsConnectionFactory
-# camel.component.sjms2.connection-factory.remoteURI=amqp://localhost:5672
\ No newline at end of file
+# camel.component.sjms2.connection-factory.remoteURI=amqp://localhost:5672
diff --git a/examples/CamelJmsSourceConnector.properties
b/examples/CamelJmsSourceConnector.properties
index 2500d5a..b999e7b 100644
--- a/examples/CamelJmsSourceConnector.properties
+++ b/examples/CamelJmsSourceConnector.properties
@@ -17,7 +17,7 @@
name=CamelJmsSourceConnector
tasks.max=1
-connector.class=org.apache.camel.kafkaconnector.CamelSourceConnector
+connector.class=org.apache.camel.kafkaconnector.sjms2.CamelSjms2SourceConnector
key.converter=org.apache.kafka.connect.storage.StringConverter
value.converter=org.apache.kafka.connect.storage.StringConverter
diff --git a/examples/CamelSlackSinkConnector.properties
b/examples/CamelSlackSinkConnector.properties
index bfe6bcd..53e6626 100644
--- a/examples/CamelSlackSinkConnector.properties
+++ b/examples/CamelSlackSinkConnector.properties
@@ -23,4 +23,4 @@ key.converter=org.apache.kafka.connect.storage.StringConverter
camel.sink.endpoint.webhookUrl=https://hooks.slack.com/path/to/id
camel.sink.path.channel=#opensourcetest
-topics=my-topic
\ No newline at end of file
+topics=my-topic
diff --git a/examples/CamelTelegramSourceConnector.properties
b/examples/CamelTelegramSourceConnector.properties
index 5c69fcc..3f8783e 100644
--- a/examples/CamelTelegramSourceConnector.properties
+++ b/examples/CamelTelegramSourceConnector.properties
@@ -17,7 +17,7 @@
name=CamelTelegramSourceConnector
tasks.max=1
-connector.class=org.apache.camel.kafkaconnector.CamelSourceConnector
+connector.class=org.apache.camel.kafkaconnector.telegram.CamelTelegramSourceConnector
key.converter=org.apache.kafka.connect.storage.StringConverter
value.converter=org.apache.kafka.connect.storage.StringConverter
