camel-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From acosent...@apache.org
Subject [camel-kafka-connector-examples] branch master updated: Docker sink pull example: Added some possible approaches
Date Wed, 20 Jan 2021 13:39:21 GMT
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


The following commit(s) were added to refs/heads/master by this push:
     new 641a54c  Docker sink pull example: Added some possible approaches
641a54c is described below

commit 641a54c29e25b08caac62a0757e6d7bdd2f03a8c
Author: Andrea Cosentino <ancosen@gmail.com>
AuthorDate: Wed Jan 20 14:38:04 2021 +0100

    Docker sink pull example: Added some possible approaches
---
 docker/docker-sink-pull/README.adoc | 41 +++++++++++++++++++++++++++++++++++--
 1 file changed, 39 insertions(+), 2 deletions(-)

diff --git a/docker/docker-sink-pull/README.adoc b/docker/docker-sink-pull/README.adoc
index 35e916b..14e9319 100644
--- a/docker/docker-sink-pull/README.adoc
+++ b/docker/docker-sink-pull/README.adoc
@@ -78,6 +78,8 @@ Run the kafka connect with the Docker Source connector:
 $KAFKA_HOME/bin/connect-standalone.sh $KAFKA_HOME/config/connect-standalone.properties $EXAMPLES/docker/docker-sink-pull/config/CamelDockerSinkConnector.properties
 ----
 
+We just need to trigger the operation through a message
+
 On a different terminal run the kafkacat producer
 
 [source]
@@ -86,8 +88,6 @@ On a different terminal run the kafkacat producer
 % Auto-selecting Producer mode (use -P or -C to override)
 ----
 
-We just need to trigger the operation through a message
-
 After a while we should get a new memcached image in our Docker
 
 [source]
@@ -96,3 +96,40 @@ After a while we should get a new memcached image in our Docker
 REPOSITORY                                                               TAG            
    IMAGE ID            CREATED             SIZE
 memcached                                                                latest         
    9f547b64a127        7 days ago          82.4MB
 ----
+
+You can use a different approach and define everything through headers. In this case the
correct configuration for the connector would be
+
+[source]
+----
+name=CamelDockerSinkConnector
+connector.class=org.apache.camel.kafkaconnector.docker.CamelDockerSinkConnector
+tasks.max=1
+
+key.converter=org.apache.kafka.connect.storage.StringConverter
+value.converter=org.apache.kafka.connect.storage.StringConverter
+
+topics=mytopic
+
+camel.component.docker.host=/var/run/docker.sock
+camel.component.docker.socket=true
+camel.sink.path.operation=imagepull
+camel.sink.endpoint.username=<username>
+camel.sink.endpoint.password=<password>
+----
+
+And then send the following message
+
+[source]
+----
+> echo "test" | ./kafkacat -b localhost:9092 -t pereppe -H "CamelHeader.CamelDockerRepository=openjdk"
-H "CamelHeader.CamelDockerTag=15.0.2-jdk"
+% Auto-selecting Producer mode (use -P or -C to override)
+----
+
+After a while you should see
+
+[source]
+----
+> docker images
+REPOSITORY                                                               TAG            
    IMAGE ID            CREATED             SIZE
+openjdk                                                                  15.0.2-jdk     
    84a383f5b038        13 hours ago        486MB
+----


Mime
View raw message