You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by ac...@apache.org on 2020/10/30 15:44:08 UTC
[camel-kafka-connector-examples] branch aws2-s3-source-fix created
(now 0284cfa)
This is an automated email from the ASF dual-hosted git repository.
acosentino pushed a change to branch aws2-s3-source-fix
in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector-examples.git.
at 0284cfa AWS2-S3-Source Example: Fixed value converter
This branch includes the following new commits:
new 8dce6ed AWS2-S3-Minio-Source: Fixed value converter
new 15d70c7 AWS2-S3-move-after-read source example: Fixed value converter
new 0284cfa AWS2-S3-Source Example: Fixed value converter
The 3 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
[camel-kafka-connector-examples] 02/03: AWS2-S3-move-after-read
source example: Fixed value converter
Posted by ac...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
acosentino pushed a commit to branch aws2-s3-source-fix
in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector-examples.git
commit 15d70c7725599a134e3b5d72822f05edb38e506f
Author: Andrea Cosentino <an...@gmail.com>
AuthorDate: Fri Oct 30 16:41:09 2020 +0100
AWS2-S3-move-after-read source example: Fixed value converter
---
aws2-s3/aws2-s3-move-after-read/README.adoc | 6 +++---
.../config/CamelAWS2S3SourceConnector.properties | 2 +-
.../config/openshift/aws2-s3-source-connector.yaml | 2 +-
3 files changed, 5 insertions(+), 5 deletions(-)
diff --git a/aws2-s3/aws2-s3-move-after-read/README.adoc b/aws2-s3/aws2-s3-move-after-read/README.adoc
index 33a754f..15442e1 100644
--- a/aws2-s3/aws2-s3-move-after-read/README.adoc
+++ b/aws2-s3/aws2-s3-move-after-read/README.adoc
@@ -40,7 +40,7 @@ Open the AWS2 S3 configuration file
name=CamelAWS2S3SourceConnector
connector.class=org.apache.camel.kafkaconnector.aws2s3.CamelAws2s3SourceConnector
key.converter=org.apache.kafka.connect.storage.StringConverter
-value.converter=org.apache.kafka.connect.storage.StringConverter
+value.converter=org.apache.kafka.connect.converters.ByteArrayConverter
camel.source.maxPollDuration=10000
@@ -216,7 +216,7 @@ oc exec -i `oc get pods --field-selector status.phase=Running -l strimzi.io/name
"connector.class": "org.apache.camel.kafkaconnector.aws2s3.CamelAws2s3SourceConnector",
"tasks.max": "1",
"key.converter": "org.apache.kafka.connect.storage.StringConverter",
- "value.converter": "org.apache.kafka.connect.storage.StringConverter",
+ "value.converter": "org.apache.kafka.connect.converters.ByteArrayConverter",
"topics": "sqs-topic",
"camel.source.path.bucketNameOrArn": "camel-kafka-connector",
"camel.source.maxPollDuration": 10000,
@@ -247,7 +247,7 @@ spec:
tasksMax: 1
config:
key.converter: org.apache.kafka.connect.storage.StringConverter
- value.converter: org.apache.kafka.connect.storage.StringConverter
+ value.converter: org.apache.kafka.connect.converters.ByteArrayConverter
topics: s3-topic
camel.source.path.bucketNameOrArn: camel-kafka-connector
camel.source.maxPollDuration: 10000
diff --git a/aws2-s3/aws2-s3-move-after-read/config/CamelAWS2S3SourceConnector.properties b/aws2-s3/aws2-s3-move-after-read/config/CamelAWS2S3SourceConnector.properties
index 5af6726..0938e61 100644
--- a/aws2-s3/aws2-s3-move-after-read/config/CamelAWS2S3SourceConnector.properties
+++ b/aws2-s3/aws2-s3-move-after-read/config/CamelAWS2S3SourceConnector.properties
@@ -18,7 +18,7 @@
name=CamelAWS2S3SourceConnector
connector.class=org.apache.camel.kafkaconnector.aws2s3.CamelAws2s3SourceConnector
key.converter=org.apache.kafka.connect.storage.StringConverter
-value.converter=org.apache.kafka.connect.storage.StringConverter
+value.converter=org.apache.kafka.connect.converters.ByteArrayConverter
camel.source.maxPollDuration=10000
diff --git a/aws2-s3/aws2-s3-move-after-read/config/openshift/aws2-s3-source-connector.yaml b/aws2-s3/aws2-s3-move-after-read/config/openshift/aws2-s3-source-connector.yaml
index 977aaf1..186840a 100644
--- a/aws2-s3/aws2-s3-move-after-read/config/openshift/aws2-s3-source-connector.yaml
+++ b/aws2-s3/aws2-s3-move-after-read/config/openshift/aws2-s3-source-connector.yaml
@@ -10,7 +10,7 @@ spec:
tasksMax: 1
config:
key.converter: org.apache.kafka.connect.storage.StringConverter
- value.converter: org.apache.kafka.connect.storage.StringConverter
+ value.converter: org.apache.kafka.connect.converters.ByteArrayConverter
topics: s3-topic
camel.source.path.bucketNameOrArn: camel-kafka-connector
camel.source.maxPollDuration: 10000
[camel-kafka-connector-examples] 03/03: AWS2-S3-Source Example:
Fixed value converter
Posted by ac...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
acosentino pushed a commit to branch aws2-s3-source-fix
in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector-examples.git
commit 0284cfadbe3297ec082153c2ca52447e42a587d5
Author: Andrea Cosentino <an...@gmail.com>
AuthorDate: Fri Oct 30 16:43:38 2020 +0100
AWS2-S3-Source Example: Fixed value converter
---
aws2-s3/aws2-s3-source/README.adoc | 6 +++---
aws2-s3/aws2-s3-source/config/CamelAWS2S3SourceConnector.properties | 2 +-
.../aws2-s3-source/config/openshift/aws2-s3-source-connector.yaml | 2 +-
3 files changed, 5 insertions(+), 5 deletions(-)
diff --git a/aws2-s3/aws2-s3-source/README.adoc b/aws2-s3/aws2-s3-source/README.adoc
index a238514..a8a3f0e 100644
--- a/aws2-s3/aws2-s3-source/README.adoc
+++ b/aws2-s3/aws2-s3-source/README.adoc
@@ -40,7 +40,7 @@ Open the AWS2 S3 configuration file
name=CamelAWS2S3SourceConnector
connector.class=org.apache.camel.kafkaconnector.aws2s3.CamelAws2s3SourceConnector
key.converter=org.apache.kafka.connect.storage.StringConverter
-value.converter=org.apache.kafka.connect.storage.StringConverter
+value.converter=org.apache.kafka.connect.converters.ByteArrayConverter
camel.source.maxPollDuration=10000
@@ -212,7 +212,7 @@ oc exec -i `oc get pods --field-selector status.phase=Running -l strimzi.io/name
"connector.class": "org.apache.camel.kafkaconnector.aws2s3.CamelAws2s3SourceConnector",
"tasks.max": "1",
"key.converter": "org.apache.kafka.connect.storage.StringConverter",
- "value.converter": "org.apache.kafka.connect.storage.StringConverter",
+ "value.converter": "org.apache.kafka.connect.converters.ByteArrayConverter",
"topics": "sqs-topic",
"camel.source.path.bucketNameOrArn": "camel-kafka-connector",
"camel.source.maxPollDuration": 10000,
@@ -241,7 +241,7 @@ spec:
tasksMax: 1
config:
key.converter: org.apache.kafka.connect.storage.StringConverter
- value.converter: org.apache.kafka.connect.storage.StringConverter
+ value.converter: org.apache.kafka.connect.converters.ByteArrayConverter
topics: s3-topic
camel.source.path.bucketNameOrArn: camel-kafka-connector
camel.source.maxPollDuration: 10000
diff --git a/aws2-s3/aws2-s3-source/config/CamelAWS2S3SourceConnector.properties b/aws2-s3/aws2-s3-source/config/CamelAWS2S3SourceConnector.properties
index fda48cf..487e96e 100644
--- a/aws2-s3/aws2-s3-source/config/CamelAWS2S3SourceConnector.properties
+++ b/aws2-s3/aws2-s3-source/config/CamelAWS2S3SourceConnector.properties
@@ -18,7 +18,7 @@
name=CamelAWS2S3SourceConnector
connector.class=org.apache.camel.kafkaconnector.aws2s3.CamelAws2s3SourceConnector
key.converter=org.apache.kafka.connect.storage.StringConverter
-value.converter=org.apache.kafka.connect.storage.StringConverter
+value.converter=org.apache.kafka.connect.converters.ByteArrayConverter
camel.source.maxPollDuration=10000
diff --git a/aws2-s3/aws2-s3-source/config/openshift/aws2-s3-source-connector.yaml b/aws2-s3/aws2-s3-source/config/openshift/aws2-s3-source-connector.yaml
index 98d121e..4893082 100644
--- a/aws2-s3/aws2-s3-source/config/openshift/aws2-s3-source-connector.yaml
+++ b/aws2-s3/aws2-s3-source/config/openshift/aws2-s3-source-connector.yaml
@@ -10,7 +10,7 @@ spec:
tasksMax: 1
config:
key.converter: org.apache.kafka.connect.storage.StringConverter
- value.converter: org.apache.kafka.connect.storage.StringConverter
+ value.converter: org.apache.kafka.connect.converters.ByteArrayConverter
topics: s3-topic
camel.source.path.bucketNameOrArn: camel-kafka-connector
camel.source.maxPollDuration: 10000
[camel-kafka-connector-examples] 01/03: AWS2-S3-Minio-Source: Fixed
value converter
Posted by ac...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
acosentino pushed a commit to branch aws2-s3-source-fix
in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector-examples.git
commit 8dce6ed5d7a43c391ca098691e05dc3d3e6a45ab
Author: Andrea Cosentino <an...@gmail.com>
AuthorDate: Fri Oct 30 16:39:42 2020 +0100
AWS2-S3-Minio-Source: Fixed value converter
---
aws2-s3/aws2-s3-minio-source/README.adoc | 2 +-
.../aws2-s3-minio-source/config/CamelAWS2S3SourceConnector.properties | 2 +-
2 files changed, 2 insertions(+), 2 deletions(-)
diff --git a/aws2-s3/aws2-s3-minio-source/README.adoc b/aws2-s3/aws2-s3-minio-source/README.adoc
index 8a7d4e2..91ccee2 100644
--- a/aws2-s3/aws2-s3-minio-source/README.adoc
+++ b/aws2-s3/aws2-s3-minio-source/README.adoc
@@ -52,7 +52,7 @@ Open the AWS2 S3 configuration file for MinIO
name=CamelAWS2S3SourceConnector
connector.class=org.apache.camel.kafkaconnector.aws2s3.CamelAws2s3SourceConnector
key.converter=org.apache.kafka.connect.storage.StringConverter
-value.converter=org.apache.kafka.connect.storage.StringConverter
+value.converter=org.apache.kafka.connect.converters.ByteArrayConverter
camel.source.maxPollDuration=10000
diff --git a/aws2-s3/aws2-s3-minio-source/config/CamelAWS2S3SourceConnector.properties b/aws2-s3/aws2-s3-minio-source/config/CamelAWS2S3SourceConnector.properties
index 1d0826e..3b0d2a2 100644
--- a/aws2-s3/aws2-s3-minio-source/config/CamelAWS2S3SourceConnector.properties
+++ b/aws2-s3/aws2-s3-minio-source/config/CamelAWS2S3SourceConnector.properties
@@ -18,7 +18,7 @@
name=CamelAWS2S3SourceConnector
connector.class=org.apache.camel.kafkaconnector.aws2s3.CamelAws2s3SourceConnector
key.converter=org.apache.kafka.connect.storage.StringConverter
-value.converter=org.apache.kafka.connect.storage.StringConverter
+value.converter=org.apache.kafka.connect.converters.ByteArrayConverter
camel.source.maxPollDuration=10000