This is an automated email from the ASF dual-hosted git repository.
acosentino pushed a commit to branch sink-pull-2
in repository
https://gitbox.apache.org/repos/asf/camel-kafka-connector-examples.git
commit 8edc22995a31bb4949fb4f594c20f7070ccb3052
Author: Andrea Cosentino <anco...@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
+----
