This is an automated email from the ASF dual-hosted git repository. acosentino pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector-examples.git
commit a6963cc914fb988c6e8330f2e9a0e8383f694e6e Author: Andrea Cosentino <[email protected]> AuthorDate: Tue Mar 2 13:09:07 2021 +0100 Added Google Pubsub sink connector example --- ...roperties => CamelGooglepubsubSinkConnector.properties} | 14 +++++++------- .../config/CamelGooglepubsubSourceConnector.properties | 2 +- 2 files changed, 8 insertions(+), 8 deletions(-) diff --git a/google-pubsub/google-pubsub-sink/config/CamelGooglepubsubSourceConnector.properties b/google-pubsub/google-pubsub-sink/config/CamelGooglepubsubSinkConnector.properties similarity index 76% copy from google-pubsub/google-pubsub-sink/config/CamelGooglepubsubSourceConnector.properties copy to google-pubsub/google-pubsub-sink/config/CamelGooglepubsubSinkConnector.properties index a040c4a..8fbdd0b 100644 --- a/google-pubsub/google-pubsub-sink/config/CamelGooglepubsubSourceConnector.properties +++ b/google-pubsub/google-pubsub-sink/config/CamelGooglepubsubSinkConnector.properties @@ -15,14 +15,14 @@ # limitations under the License. # -name=CamelGoogle-pubsubSourceConnector -connector.class=org.apache.camel.kafkaconnector.googlepubsub.CamelGooglepubsubSourceConnector +name=CamelGoogle-pubsubSinkConnector +connector.class=org.apache.camel.kafkaconnector.googlepubsub.CamelGooglepubsubSinkConnector tasks.max=1 key.converter=org.apache.kafka.connect.storage.StringConverter -value.converter=org.apache.kafka.connect.converters.ByteArrayConverter +value.converter=org.apache.kafka.connect.storage.StringConverter -topics=mytopic +topics=pubsub-topic -camel.source.path.destinationName=test-sub -camel.source.path.projectId=testpubsub-306306 -camel.source.endpoint.synchronousPull=true +camel.sink.path.destinationName=test +camel.sink.path.projectId=testpubsub-306306 +camel.sink.endpoint.synchronousPull=true diff --git a/google-pubsub/google-pubsub-sink/config/CamelGooglepubsubSourceConnector.properties b/google-pubsub/google-pubsub-sink/config/CamelGooglepubsubSourceConnector.properties index a040c4a..2e7a8d2 100644 --- a/google-pubsub/google-pubsub-sink/config/CamelGooglepubsubSourceConnector.properties +++ b/google-pubsub/google-pubsub-sink/config/CamelGooglepubsubSourceConnector.properties @@ -21,7 +21,7 @@ tasks.max=1 key.converter=org.apache.kafka.connect.storage.StringConverter value.converter=org.apache.kafka.connect.converters.ByteArrayConverter -topics=mytopic +topics=mytopic-source camel.source.path.destinationName=test-sub camel.source.path.projectId=testpubsub-306306
