This is an automated email from the ASF dual-hosted git repository. acosentino pushed a commit to branch tag-0.11.x in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector-examples.git
commit 2f46610f0b9dde209ec40d8dd5e6612ce593feaf Author: Andrea Cosentino <[email protected]> AuthorDate: Tue Oct 5 11:11:30 2021 +0200 Other Examples: Moved to 0.11.0 --- other-examples/error-handling-sink/README.adoc | 4 +-- pgevent/pgevent-source/README.adoc | 4 +-- quartz/quartz-source/README.adoc | 4 +-- rabbitmq/rabbitmq-sink/README.adoc | 4 +-- rabbitmq/rabbitmq-source/README.adoc | 4 +-- scp/scp-sink/README.adoc | 8 ++--- sftp/sftp-sink/README.adoc | 4 +-- sftp/sftp-source/README.adoc | 26 ++++++++--------- slack/slack-sink/README.adoc | 10 +++---- .../README.adoc | 34 +++++++++++----------- .../README.adoc | 34 +++++++++++----------- slack/slack-source/README.adoc | 10 +++---- sql/sql-sink/README.adoc | 4 +-- sql/sql-source/README.adoc | 4 +-- ssh/ssh-sink/README.adoc | 4 +-- ssh/ssh-source/README.adoc | 24 +++++++-------- telegram/telegram-sink/README.adoc | 10 +++---- telegram/telegram-source/README.adoc | 10 +++---- twitter/twitter-direct-message-sink/README.adoc | 4 +-- twitter/twitter-direct-message-source/README.adoc | 4 +-- twitter/twitter-search-source/README.adoc | 4 +-- twitter/twitter-timeline-sink/README.adoc | 4 +-- twitter/twitter-timeline-source/README.adoc | 6 ++-- 23 files changed, 112 insertions(+), 112 deletions(-) diff --git a/other-examples/error-handling-sink/README.adoc b/other-examples/error-handling-sink/README.adoc index b79ab29..ae32c6c 100644 --- a/other-examples/error-handling-sink/README.adoc +++ b/other-examples/error-handling-sink/README.adoc @@ -30,8 +30,8 @@ In this example we'll use `/home/oscerd/connectors/` ``` > cd /home/otavio/connectors/ -> wget https://repo1.maven.org/maven2/org/apache/camel/kafkaconnector/camel-sjms2-kafka-connector/0.10.1/camel-sjms2-kafka-connector-0.10.1-package.tar.gz -> untar.gz camel-sjms2-kafka-connector-0.10.1-package.tar.gz +> wget https://repo1.maven.org/maven2/org/apache/camel/kafkaconnector/camel-sjms2-kafka-connector/0.11.0/camel-sjms2-kafka-connector-0.11.0-package.tar.gz +> untar.gz camel-sjms2-kafka-connector-0.11.0-package.tar.gz ``` Open the SJMS2 configuration file diff --git a/pgevent/pgevent-source/README.adoc b/pgevent/pgevent-source/README.adoc index 2b7477c..207a589 100644 --- a/pgevent/pgevent-source/README.adoc +++ b/pgevent/pgevent-source/README.adoc @@ -24,8 +24,8 @@ Download the connector package tar.gz and extract the content to a directory. In [source] ---- > cd /home/oscerd/connectors/ -> wget https://repo1.maven.org/maven2/org/apache/camel/kafkaconnector/camel-pgevent-kafka-connector/0.10.1/camel-pgevent-kafka-connector-0.10.1-package.tar.gz -> untar.gz camel-pgevent-kafka-connector-0.10.1-package.tar.gz +> wget https://repo1.maven.org/maven2/org/apache/camel/kafkaconnector/camel-pgevent-kafka-connector/0.11.0/camel-pgevent-kafka-connector-0.11.0-package.tar.gz +> untar.gz camel-pgevent-kafka-connector-0.11.0-package.tar.gz ---- === Configuring Kafka Connect diff --git a/quartz/quartz-source/README.adoc b/quartz/quartz-source/README.adoc index 785ad46..a8bf9fd 100644 --- a/quartz/quartz-source/README.adoc +++ b/quartz/quartz-source/README.adoc @@ -20,8 +20,8 @@ Download the connector package tar.gz and extract the content to a directory. In [source] ---- > cd /home/oscerd/connectors/ -> wget https://repo1.maven.org/maven2/org/apache/camel/kafkaconnector/camel-quartz-kafka-connector/0.10.1/camel-quartz-kafka-connector-0.10.1-package.tar.gz -> untar.gz camel-quartz-kafka-connector-0.10.1-package.tar.gz +> wget https://repo1.maven.org/maven2/org/apache/camel/kafkaconnector/camel-quartz-kafka-connector/0.11.0/camel-quartz-kafka-connector-0.11.0-package.tar.gz +> untar.gz camel-quartz-kafka-connector-0.11.0-package.tar.gz ---- We are now ready diff --git a/rabbitmq/rabbitmq-sink/README.adoc b/rabbitmq/rabbitmq-sink/README.adoc index f97228c..e1ef09e 100644 --- a/rabbitmq/rabbitmq-sink/README.adoc +++ b/rabbitmq/rabbitmq-sink/README.adoc @@ -28,8 +28,8 @@ In this example we'll use `/home/oscerd/connectors/` ``` > cd /home/oscerd/connectors/ -> wget https://repo1.maven.org/maven2/org/apache/camel/kafkaconnector/camel-rabbitmq-kafka-connector/0.10.1/camel-rabbitmq-kafka-connector-0.10.1-package.tar.gz -> untar.gz camel-rabbitmq-kafka-connector-0.10.1-package.tar.gz +> wget https://repo1.maven.org/maven2/org/apache/camel/kafkaconnector/camel-rabbitmq-kafka-connector/0.11.0/camel-rabbitmq-kafka-connector-0.11.0-package.tar.gz +> untar.gz camel-rabbitmq-kafka-connector-0.11.0-package.tar.gz ``` ## Setting up RabbitMQ diff --git a/rabbitmq/rabbitmq-source/README.adoc b/rabbitmq/rabbitmq-source/README.adoc index b4178e5..f22afd8 100644 --- a/rabbitmq/rabbitmq-source/README.adoc +++ b/rabbitmq/rabbitmq-source/README.adoc @@ -28,8 +28,8 @@ In this example we'll use `/home/oscerd/connectors/` ``` > cd /home/oscerd/connectors/ -> wget https://repo1.maven.org/maven2/org/apache/camel/kafkaconnector/camel-rabbitmq-kafka-connector/0.10.1/camel-rabbitmq-kafka-connector-0.10.1-package.tar.gz -> untar.gz camel-rabbitmq-kafka-connector-0.10.1-package.tar.gz +> wget https://repo1.maven.org/maven2/org/apache/camel/kafkaconnector/camel-rabbitmq-kafka-connector/0.11.0/camel-rabbitmq-kafka-connector-0.11.0-package.tar.gz +> untar.gz camel-rabbitmq-kafka-connector-0.11.0-package.tar.gz ``` ## Setting up RabbitMQ diff --git a/scp/scp-sink/README.adoc b/scp/scp-sink/README.adoc index 8531afc..fe9699f 100644 --- a/scp/scp-sink/README.adoc +++ b/scp/scp-sink/README.adoc @@ -46,8 +46,8 @@ In this example we'll use `/home/oscerd/connectors/` ``` > cd /home/oscerd/connectors/ -> wget https://repo1.maven.org/maven2/org/apache/camel/kafkaconnector/camel-scp-kafka-connector/0.10.1/camel-scp-kafka-connector-0.10.1-package.tar.gz -> untar.gz camel-scp-kafka-connector-0.10.1-package.tar.gz +> wget https://repo1.maven.org/maven2/org/apache/camel/kafkaconnector/camel-scp-kafka-connector/0.11.0/camel-scp-kafka-connector-0.11.0-package.tar.gz +> untar.gz camel-scp-kafka-connector-0.11.0-package.tar.gz ``` Now it's time to setup the connectors @@ -96,8 +96,8 @@ Now we can check our docker container. root@localhost's password: Last login: Wed Feb 10 12:51:54 2021 from 172.17.0.1 root@0d813b2e5994:~# ls -mydata-20210210-135931864-F4B26643BB9D698-0000000000000001.txt -root@0d813b2e5994:~# cat mydata-20210210-135931864-F4B26643BB9D698-0000000000000001.txt +mydata-20.11.00-135931864-F4B26643BB9D698-0000000000000001.txt +root@0d813b2e5994:~# cat mydata-20.11.00-135931864-F4B26643BB9D698-0000000000000001.txt Hello from camel-scp-kafka-connector ``` diff --git a/sftp/sftp-sink/README.adoc b/sftp/sftp-sink/README.adoc index 5eeed6c..90afa94 100644 --- a/sftp/sftp-sink/README.adoc +++ b/sftp/sftp-sink/README.adoc @@ -60,8 +60,8 @@ Download the connector package tar.gz and extract the content to the plugin.path [source] ---- > cd /home/oscerd/connectors/ -> wget https://repo1.maven.org/maven2/org/apache/camel/kafkaconnector/camel-sftp-kafka-connector/0.10.1/camel-sftp-kafka-connector-0.10.1-package.tar.gz -> untar.gz camel-sftp-kafka-connector-0.10.1-package.tar.gz +> wget https://repo1.maven.org/maven2/org/apache/camel/kafkaconnector/camel-sftp-kafka-connector/0.11.0/camel-sftp-kafka-connector-0.11.0-package.tar.gz +> untar.gz camel-sftp-kafka-connector-0.11.0-package.tar.gz ---- Open the SFTP sink configuration file diff --git a/sftp/sftp-source/README.adoc b/sftp/sftp-source/README.adoc index e4698de..db5de15 100644 --- a/sftp/sftp-source/README.adoc +++ b/sftp/sftp-source/README.adoc @@ -41,7 +41,7 @@ and set the `plugin.path` property to your choosen location You'll need to build your connector starting from an archetype: ``` -> mvn archetype:generate -DarchetypeGroupId=org.apache.camel.kafkaconnector.archetypes -DarchetypeArtifactId=camel-kafka-connector-extensible-archetype -DarchetypeVersion=0.10.1 +> mvn archetype:generate -DarchetypeGroupId=org.apache.camel.kafkaconnector.archetypes -DarchetypeArtifactId=camel-kafka-connector-extensible-archetype -DarchetypeVersion=0.11.0 [INFO] Scanning for projects... [INFO] [INFO] ------------------< org.apache.maven:standalone-pom >------------------- @@ -55,34 +55,34 @@ You'll need to build your connector starting from an archetype: [INFO] [INFO] --- maven-archetype-plugin:3.1.2:generate (default-cli) @ standalone-pom --- [INFO] Generating project in Interactive mode -[INFO] Archetype repository not defined. Using the one from [org.apache.camel.kafkaconnector.archetypes:camel-kafka-connector-extensible-archetype:0.10.1] found in catalog remote +[INFO] Archetype repository not defined. Using the one from [org.apache.camel.kafkaconnector.archetypes:camel-kafka-connector-extensible-archetype:0.11.0] found in catalog remote Define value for property 'groupId': org.apache.camel.kafkaconnector Define value for property 'artifactId': sftp-extended -Define value for property 'version' 1.0-SNAPSHOT: : 0.10.1 +Define value for property 'version' 1.0-SNAPSHOT: : 0.11.0 Define value for property 'package' com.github.oscerd: : Define value for property 'camel-kafka-connector-name': camel-sftp-kafka-connector -[INFO] Using property: camel-kafka-connector-version = 0.10.1 +[INFO] Using property: camel-kafka-connector-version = 0.11.0 Confirm properties configuration: groupId: org.apache.camel.kafkaconnector artifactId: sftp-extended -version: 0.10.1 +version: 0.11.0 package: com.github.oscerd camel-kafka-connector-name: camel-sftp-kafka-connector -camel-kafka-connector-version: 0.10.1 +camel-kafka-connector-version: 0.11.0 Y: : Y [INFO] ---------------------------------------------------------------------------- -[INFO] Using following parameters for creating project from Archetype: camel-kafka-connector-extensible-archetype:0.10.1 +[INFO] Using following parameters for creating project from Archetype: camel-kafka-connector-extensible-archetype:0.11.0 [INFO] ---------------------------------------------------------------------------- [INFO] Parameter: groupId, Value: org.apache.camel.kafkaconnector [INFO] Parameter: artifactId, Value: sftp-extended -[INFO] Parameter: version, Value: 0.10.1 +[INFO] Parameter: version, Value: 0.11.0 [INFO] Parameter: package, Value: org.apache.camel.kafkaconnector [INFO] Parameter: packageInPathFormat, Value: org/apache/camel/kafkaconnector [INFO] Parameter: package, Value: org.apache.camel.kafkaconnector -[INFO] Parameter: version, Value: 0.10.1 +[INFO] Parameter: version, Value: 0.11.0 [INFO] Parameter: groupId, Value: org.apache.camel.kafkaconnector [INFO] Parameter: camel-kafka-connector-name, Value: camel-sftp-kafka-connector -[INFO] Parameter: camel-kafka-connector-version, Value: 0.10.1 +[INFO] Parameter: camel-kafka-connector-version, Value: 0.11.0 [INFO] Parameter: artifactId, Value: sftp-extended [INFO] Project created from Archetype in dir: /home/workspace/miscellanea/sftp-extended [INFO] ------------------------------------------------------------------------ @@ -164,8 +164,8 @@ In this example we'll use `/home/oscerd/connectors/` as plugin.path, but we'll n ``` > cd /home/oscerd/connectors/ -> cp /home/workspace/miscellanea/sftp-extended/target/sftp-extended-0.10.1-package.tar.gz . -> untar.gz sftp-extended-0.10.1-package.tar.gz +> cp /home/workspace/miscellanea/sftp-extended/target/sftp-extended-0.11.0-package.tar.gz . +> untar.gz sftp-extended-0.11.0-package.tar.gz ``` Now it's time to setup the connector @@ -213,7 +213,7 @@ In another terminal, using kafkacat, you should be able to see the headers. ``` > ./kafkacat -b localhost:9092 -t mytopic -f 'Headers: %h: Message value: %s\n' % Auto-selecting Consumer mode (use -P or -C to override) -Headers: CamelHeader.CamelFileAbsolute=false,CamelHeader.CamelFileAbsolutePath=demos/file.txt,CamelHeader.CamelFileHost=localhost,CamelHeader.CamelFileLastModified=1604560.10.100,CamelHeader.CamelFileLength=29,CamelHeader.CamelFileName=file.txt,CamelHeader.CamelFileNameConsumed=file.txt,CamelHeader.CamelFileNameOnly=file.txt,CamelHeader.CamelFileParent=demos,CamelHeader.CamelFilePath=demos//file.txt,CamelHeader.CamelFileRelativePath=file.txt,CamelHeader.CamelFtpReplyCode=0,CamelHeader.Ca [...] +Headers: CamelHeader.CamelFileAbsolute=false,CamelHeader.CamelFileAbsolutePath=demos/file.txt,CamelHeader.CamelFileHost=localhost,CamelHeader.CamelFileLastModified=1604560.11.000,CamelHeader.CamelFileLength=29,CamelHeader.CamelFileName=file.txt,CamelHeader.CamelFileNameConsumed=file.txt,CamelHeader.CamelFileNameOnly=file.txt,CamelHeader.CamelFileParent=demos,CamelHeader.CamelFilePath=demos//file.txt,CamelHeader.CamelFileRelativePath=file.txt,CamelHeader.CamelFtpReplyCode=0,CamelHeader.Ca [...] % Reached end of topic mytopic [0] at offset 1 ``` diff --git a/slack/slack-sink/README.adoc b/slack/slack-sink/README.adoc index 8f9a6af..6c876b2 100644 --- a/slack/slack-sink/README.adoc +++ b/slack/slack-sink/README.adoc @@ -44,8 +44,8 @@ In this example we'll use `/home/oscerd/connectors/` ``` > cd /home/oscerd/connectors/ -> wget https://repo1.maven.org/maven2/org/apache/camel/kafkaconnector/camel-slack-kafka-connector/0.10.1/camel-slack-kafka-connector-0.10.1-package.tar.gz -> untar.gz camel-slack-kafka-connector-0.10.1-package.tar.gz +> wget https://repo1.maven.org/maven2/org/apache/camel/kafkaconnector/camel-slack-kafka-connector/0.11.0/camel-slack-kafka-connector-0.11.0-package.tar.gz +> untar.gz camel-slack-kafka-connector-0.11.0-package.tar.gz ``` Now it's time to setup the connectors @@ -149,8 +149,8 @@ So we need to do something like this: ``` > cd my-connectors/ -> wget https://repo1.maven.org/maven2/org/apache/camel/kafkaconnector/camel-slack-kafka-connector/0.10.1/camel-slack-kafka-connector-0.10.1-package.tar.gz -> untar.gz camel-slack-kafka-connector-0.10.1-package.tar.gz +> wget https://repo1.maven.org/maven2/org/apache/camel/kafkaconnector/camel-slack-kafka-connector/0.11.0/camel-slack-kafka-connector-0.11.0-package.tar.gz +> untar.gz camel-slack-kafka-connector-0.11.0-package.tar.gz ``` Now we can start the build @@ -175,7 +175,7 @@ You should see something like this: [source,json,options="nowrap"] ---- -[{"class":"org.apache.camel.kafkaconnector.CamelSinkConnector","type":"sink","version":"0.10.1"},{"class":"org.apache.camel.kafkaconnector.CamelSourceConnector","type":"source","version":"0.10.1"},{"class":"org.apache.camel.kafkaconnector.slack.CamelSlackSinkConnector","type":"sink","version":"0.10.1"},{"class":"org.apache.camel.kafkaconnector.slack.CamelSlackSourceConnector","type":"source","version":"0.10.1"},{"class":"org.apache.kafka.connect.file.FileStreamSinkConnector","type":"sink [...] +[{"class":"org.apache.camel.kafkaconnector.CamelSinkConnector","type":"sink","version":"0.11.0"},{"class":"org.apache.camel.kafkaconnector.CamelSourceConnector","type":"source","version":"0.11.0"},{"class":"org.apache.camel.kafkaconnector.slack.CamelSlackSinkConnector","type":"sink","version":"0.11.0"},{"class":"org.apache.camel.kafkaconnector.slack.CamelSlackSourceConnector","type":"source","version":"0.11.0"},{"class":"org.apache.kafka.connect.file.FileStreamSinkConnector","type":"sink [...] ---- ### Set the Bot Token as secret (optional) diff --git a/slack/slack-source-apicurio-schema-registry/README.adoc b/slack/slack-source-apicurio-schema-registry/README.adoc index 15fcbef..050e18b 100644 --- a/slack/slack-source-apicurio-schema-registry/README.adoc +++ b/slack/slack-source-apicurio-schema-registry/README.adoc @@ -66,7 +66,7 @@ and set the `plugin.path` property to your choosen location You'll need to build your connector starting from an archetype: ``` -> mvn archetype:generate -DarchetypeGroupId=org.apache.camel.kafkaconnector.archetypes -DarchetypeArtifactId=camel-kafka-connector-extensible-archetype -DarchetypeVersion=0.10.1 +> mvn archetype:generate -DarchetypeGroupId=org.apache.camel.kafkaconnector.archetypes -DarchetypeArtifactId=camel-kafka-connector-extensible-archetype -DarchetypeVersion=0.11.0 [INFO] Scanning for projects... [INFO] [INFO] ------------------< org.apache.maven:standalone-pom >------------------- @@ -83,38 +83,38 @@ You'll need to build your connector starting from an archetype: [INFO] Archetype repository not defined. Using the one from [org.apache.camel.kafkaconnector.archetypes:camel-kafka-connector-extensible-archetype:0.4.0] found in catalog remote Define value for property 'groupId': org.apache.camel.kafkaconnector Define value for property 'artifactId': slack-extended -Define value for property 'version' 1.0-SNAPSHOT: : 0.10.1 +Define value for property 'version' 1.0-SNAPSHOT: : 0.11.0 Define value for property 'package' org.apache.camel.kafkaconnector: : Define value for property 'camel-kafka-connector-name': camel-slack-kafka-connector -[INFO] Using property: camel-kafka-connector-version = 0.10.1 +[INFO] Using property: camel-kafka-connector-version = 0.11.0 Confirm properties configuration: groupId: org.apache.camel.kafkaconnector artifactId: slack-extended -version: 0.10.1 +version: 0.11.0 package: org.apache.camel.kafkaconnector camel-kafka-connector-name: camel-slack-kafka-connector -camel-kafka-connector-version: 0.10.1 +camel-kafka-connector-version: 0.11.0 Y: : y [INFO] ---------------------------------------------------------------------------- -[INFO] Using following parameters for creating project from Archetype: camel-kafka-connector-extensible-archetype:0.10.1 +[INFO] Using following parameters for creating project from Archetype: camel-kafka-connector-extensible-archetype:0.11.0 [INFO] ---------------------------------------------------------------------------- [INFO] Parameter: groupId, Value: org.apache.camel.kafkaconnector [INFO] Parameter: artifactId, Value: slack-extended -[INFO] Parameter: version, Value: 0.10.1 +[INFO] Parameter: version, Value: 0.11.0 [INFO] Parameter: package, Value: org.apache.camel.kafkaconnector [INFO] Parameter: packageInPathFormat, Value: org/apache/camel/kafkaconnector [INFO] Parameter: package, Value: org.apache.camel.kafkaconnector -[INFO] Parameter: version, Value: 0.10.1 +[INFO] Parameter: version, Value: 0.11.0 [INFO] Parameter: groupId, Value: org.apache.camel.kafkaconnector [INFO] Parameter: camel-kafka-connector-name, Value: camel-slack-kafka-connector -[INFO] Parameter: camel-kafka-connector-version, Value: 0.10.1 +[INFO] Parameter: camel-kafka-connector-version, Value: 0.11.0 [INFO] Parameter: artifactId, Value: slack-extended [INFO] Project created from Archetype in dir: /home/oscerd/playground/slack-extended [INFO] ------------------------------------------------------------------------ [INFO] BUILD SUCCESS [INFO] ------------------------------------------------------------------------ [INFO] Total time: 39.295 s -[INFO] Finished at: 2020-10-13T09:16:51+02:00 +[INFO] Finished at: 2020.11.03T09:16:51+02:00 [INFO] ------------------------------------------------------------------------ > cd /home/workspace/miscellanea/slack-extended ``` @@ -126,7 +126,7 @@ Now we need to edit the POM . . . - <version>0.10.1</version> + <version>0.11.0</version> <name>A Camel Kafka Connector extended</name> <properties> @@ -151,12 +151,12 @@ Now we need to edit the POM <dependency> <groupId>org.apache.camel.kafkaconnector</groupId> <artifactId>camel-kafka-connector</artifactId> - <version>0.10.1</version> + <version>0.11.0</version> </dependency> <dependency> <groupId>org.apache.camel.kafkaconnector</groupId> <artifactId>camel-slack-kafka-connector</artifactId> - <version>0.10.1</version> + <version>0.11.0</version> </dependency> <dependency> <groupId>io.apicurio</groupId> @@ -186,8 +186,8 @@ In this example we'll use `/home/oscerd/connectors/` as plugin.path, but we'll n ``` > cd /home/oscerd/connectors/ -> cp /home/workspace/miscellanea/slack-extended/target/slack-extended-0.10.1-package.tar.gz . -> untar.gz slack-extended-0.10.1-package.tar.gz +> cp /home/workspace/miscellanea/slack-extended/target/slack-extended-0.11.0-package.tar.gz . +> untar.gz slack-extended-0.11.0-package.tar.gz ``` Now it's time to setup the connector @@ -244,14 +244,14 @@ We can also collect some version meta info for the schema ``` curl -X GET http://localhost:8080/api/artifacts/mytopic-value/versions/1/meta -{"version":1,"createdOn":160.10.1208148,"type":"KCONNECT","globalId":1,"state":"ENABLED","id":"mytopic-value"} +{"version":1,"createdOn":160.11.0208148,"type":"KCONNECT","globalId":1,"state":"ENABLED","id":"mytopic-value"} ``` and some meta info too ``` curl -X GET http://localhost:8080/api/artifacts/mytopic-value/meta -{"createdOn":160.10.1208148,"modifiedOn":160.10.1208148,"id":"mytopic-value","version":1,"type":"KCONNECT","globalId":1,"state":"ENABLED"} +{"createdOn":160.11.0208148,"modifiedOn":160.11.0208148,"id":"mytopic-value","version":1,"type":"KCONNECT","globalId":1,"state":"ENABLED"} ``` and finally the schema content diff --git a/slack/slack-source-avro-apicurio-schema-registry/README.adoc b/slack/slack-source-avro-apicurio-schema-registry/README.adoc index a86d256..857d7aa 100644 --- a/slack/slack-source-avro-apicurio-schema-registry/README.adoc +++ b/slack/slack-source-avro-apicurio-schema-registry/README.adoc @@ -66,7 +66,7 @@ and set the `plugin.path` property to your choosen location You'll need to build your connector starting from an archetype: ``` -> mvn archetype:generate -DarchetypeGroupId=org.apache.camel.kafkaconnector.archetypes -DarchetypeArtifactId=camel-kafka-connector-extensible-archetype -DarchetypeVersion=0.10.1 +> mvn archetype:generate -DarchetypeGroupId=org.apache.camel.kafkaconnector.archetypes -DarchetypeArtifactId=camel-kafka-connector-extensible-archetype -DarchetypeVersion=0.11.0 [INFO] Scanning for projects... [INFO] [INFO] ------------------< org.apache.maven:standalone-pom >------------------- @@ -83,38 +83,38 @@ You'll need to build your connector starting from an archetype: [INFO] Archetype repository not defined. Using the one from [org.apache.camel.kafkaconnector.archetypes:camel-kafka-connector-extensible-archetype:0.4.0] found in catalog remote Define value for property 'groupId': org.apache.camel.kafkaconnector Define value for property 'artifactId': slack-extended -Define value for property 'version' 1.0-SNAPSHOT: : 0.10.1 +Define value for property 'version' 1.0-SNAPSHOT: : 0.11.0 Define value for property 'package' org.apache.camel.kafkaconnector: : Define value for property 'camel-kafka-connector-name': camel-slack-kafka-connector -[INFO] Using property: camel-kafka-connector-version = 0.10.1 +[INFO] Using property: camel-kafka-connector-version = 0.11.0 Confirm properties configuration: groupId: org.apache.camel.kafkaconnector artifactId: slack-extended -version: 0.10.1 +version: 0.11.0 package: org.apache.camel.kafkaconnector camel-kafka-connector-name: camel-slack-kafka-connector -camel-kafka-connector-version: 0.10.1 +camel-kafka-connector-version: 0.11.0 Y: : y [INFO] ---------------------------------------------------------------------------- -[INFO] Using following parameters for creating project from Archetype: camel-kafka-connector-extensible-archetype:0.10.1 +[INFO] Using following parameters for creating project from Archetype: camel-kafka-connector-extensible-archetype:0.11.0 [INFO] ---------------------------------------------------------------------------- [INFO] Parameter: groupId, Value: org.apache.camel.kafkaconnector [INFO] Parameter: artifactId, Value: slack-extended -[INFO] Parameter: version, Value: 0.10.1 +[INFO] Parameter: version, Value: 0.11.0 [INFO] Parameter: package, Value: org.apache.camel.kafkaconnector [INFO] Parameter: packageInPathFormat, Value: org/apache/camel/kafkaconnector [INFO] Parameter: package, Value: org.apache.camel.kafkaconnector -[INFO] Parameter: version, Value: 0.10.1 +[INFO] Parameter: version, Value: 0.11.0 [INFO] Parameter: groupId, Value: org.apache.camel.kafkaconnector [INFO] Parameter: camel-kafka-connector-name, Value: camel-slack-kafka-connector -[INFO] Parameter: camel-kafka-connector-version, Value: 0.10.1 +[INFO] Parameter: camel-kafka-connector-version, Value: 0.11.0 [INFO] Parameter: artifactId, Value: slack-extended [INFO] Project created from Archetype in dir: /home/oscerd/playground/slack-extended [INFO] ------------------------------------------------------------------------ [INFO] BUILD SUCCESS [INFO] ------------------------------------------------------------------------ [INFO] Total time: 39.295 s -[INFO] Finished at: 2020-10-13T09:16:51+02:00 +[INFO] Finished at: 2020.11.03T09:16:51+02:00 [INFO] ------------------------------------------------------------------------ > cd /home/workspace/miscellanea/slack-extended ``` @@ -126,7 +126,7 @@ Now we need to edit the POM . . . - <version>0.10.1</version> + <version>0.11.0</version> <name>A Camel Kafka Connector extended</name> <properties> @@ -151,12 +151,12 @@ Now we need to edit the POM <dependency> <groupId>org.apache.camel.kafkaconnector</groupId> <artifactId>camel-kafka-connector</artifactId> - <version>0.10.1</version> + <version>0.11.0</version> </dependency> <dependency> <groupId>org.apache.camel.kafkaconnector</groupId> <artifactId>camel-slack-kafka-connector</artifactId> - <version>0.10.1</version> + <version>0.11.0</version> </dependency> <dependency> <groupId>io.apicurio</groupId> @@ -184,8 +184,8 @@ In this example we'll use `/home/oscerd/connectors/` as plugin.path, but we'll n ``` > cd /home/oscerd/connectors/ -> cp /home/workspace/miscellanea/slack-extended/target/slack-extended-0.10.1-package.tar.gz . -> untar.gz slack-extended-0.10.1-package.tar.gz +> cp /home/workspace/miscellanea/slack-extended/target/slack-extended-0.11.0-package.tar.gz . +> untar.gz slack-extended-0.11.0-package.tar.gz ``` Now it's time to setup the connector @@ -247,14 +247,14 @@ We can also collect some version meta info for the schema ``` curl -X GET http://localhost:8080/api/artifacts/mytopic-value/versions/1/meta -{"version":1,"createdOn":160.10.1208148,"type":"KCONNECT","globalId":1,"state":"ENABLED","id":"mytopic-value"} +{"version":1,"createdOn":160.11.0208148,"type":"KCONNECT","globalId":1,"state":"ENABLED","id":"mytopic-value"} ``` and some meta info too ``` curl -X GET http://localhost:8080/api/artifacts/mytopic-value/meta -{"createdOn":160.10.1208148,"modifiedOn":160.10.1208148,"id":"mytopic-value","version":1,"type":"KCONNECT","globalId":1,"state":"ENABLED"} +{"createdOn":160.11.0208148,"modifiedOn":160.11.0208148,"id":"mytopic-value","version":1,"type":"KCONNECT","globalId":1,"state":"ENABLED"} ``` and finally the schema content diff --git a/slack/slack-source/README.adoc b/slack/slack-source/README.adoc index da41446..ef70d29 100644 --- a/slack/slack-source/README.adoc +++ b/slack/slack-source/README.adoc @@ -43,8 +43,8 @@ In this example we'll use `/home/oscerd/connectors/` ``` > cd /home/oscerd/connectors/ -> wget https://repo1.maven.org/maven2/org/apache/camel/kafkaconnector/camel-slack-kafka-connector/0.10.1/camel-slack-kafka-connector-0.10.1-package.tar.gz -> untar.gz camel-slack-kafka-connector-0.10.1-package.tar.gz +> wget https://repo1.maven.org/maven2/org/apache/camel/kafkaconnector/camel-slack-kafka-connector/0.11.0/camel-slack-kafka-connector-0.11.0-package.tar.gz +> untar.gz camel-slack-kafka-connector-0.11.0-package.tar.gz ``` Now it's time to setup the connectors @@ -149,8 +149,8 @@ So we need to do something like this: ``` > cd my-connectors/ -> wget https://repo1.maven.org/maven2/org/apache/camel/kafkaconnector/camel-slack-kafka-connector/0.10.1/camel-slack-kafka-connector-0.10.1-package.tar.gz -> untar.gz camel-slack-kafka-connector-0.10.1-package.tar.gz +> wget https://repo1.maven.org/maven2/org/apache/camel/kafkaconnector/camel-slack-kafka-connector/0.11.0/camel-slack-kafka-connector-0.11.0-package.tar.gz +> untar.gz camel-slack-kafka-connector-0.11.0-package.tar.gz ``` Now we can start the build @@ -175,7 +175,7 @@ You should see something like this: [source,json,options="nowrap"] ---- -[{"class":"org.apache.camel.kafkaconnector.CamelSinkConnector","type":"sink","version":"0.10.1"},{"class":"org.apache.camel.kafkaconnector.CamelSourceConnector","type":"source","version":"0.10.1"},{"class":"org.apache.camel.kafkaconnector.slack.CamelSlackSinkConnector","type":"sink","version":"0.10.1"},{"class":"org.apache.camel.kafkaconnector.slack.CamelSlackSourceConnector","type":"source","version":"0.10.1"},{"class":"org.apache.kafka.connect.file.FileStreamSinkConnector","type":"sink [...] +[{"class":"org.apache.camel.kafkaconnector.CamelSinkConnector","type":"sink","version":"0.11.0"},{"class":"org.apache.camel.kafkaconnector.CamelSourceConnector","type":"source","version":"0.11.0"},{"class":"org.apache.camel.kafkaconnector.slack.CamelSlackSinkConnector","type":"sink","version":"0.11.0"},{"class":"org.apache.camel.kafkaconnector.slack.CamelSlackSourceConnector","type":"source","version":"0.11.0"},{"class":"org.apache.kafka.connect.file.FileStreamSinkConnector","type":"sink [...] ---- ### Set the Bot Token as secret (optional) diff --git a/sql/sql-sink/README.adoc b/sql/sql-sink/README.adoc index 3a9f43d..354d920 100644 --- a/sql/sql-sink/README.adoc +++ b/sql/sql-sink/README.adoc @@ -25,8 +25,8 @@ Download the connector package tar.gz and extract the content to a directory. In [source] ---- > cd /home/oscerd/connectors/ -> wget https://repo1.maven.org/maven2/org/apache/camel/kafkaconnector/camel-sql-kafka-connector/0.10.1/camel-sql-kafka-connector-0.10.1-package.tar.gz -> untar.gz camel-sql-kafka-connector-0.10.1-package.tar.gz +> wget https://repo1.maven.org/maven2/org/apache/camel/kafkaconnector/camel-sql-kafka-connector/0.11.0/camel-sql-kafka-connector-0.11.0-package.tar.gz +> untar.gz camel-sql-kafka-connector-0.11.0-package.tar.gz ---- There is also the need of the driver for this example diff --git a/sql/sql-source/README.adoc b/sql/sql-source/README.adoc index 8f3a818..b5ef272 100644 --- a/sql/sql-source/README.adoc +++ b/sql/sql-source/README.adoc @@ -25,8 +25,8 @@ Download the connector package tar.gz and extract the content to a directory. In [source] ---- > cd /home/oscerd/connectors/ -> wget https://repo1.maven.org/maven2/org/apache/camel/kafkaconnector/camel-sql-kafka-connector/0.10.1/camel-sql-kafka-connector-0.10.1-package.tar.gz -> untar.gz camel-sql-kafka-connector-0.10.1-package.tar.gz +> wget https://repo1.maven.org/maven2/org/apache/camel/kafkaconnector/camel-sql-kafka-connector/0.11.0/camel-sql-kafka-connector-0.11.0-package.tar.gz +> untar.gz camel-sql-kafka-connector-0.11.0-package.tar.gz ---- There is also the need of the driver for this example diff --git a/ssh/ssh-sink/README.adoc b/ssh/ssh-sink/README.adoc index 7a55be3..ae9e352 100644 --- a/ssh/ssh-sink/README.adoc +++ b/ssh/ssh-sink/README.adoc @@ -46,8 +46,8 @@ In this example we'll use `/home/oscerd/connectors/` ``` > cd /home/oscerd/connectors/ -> wget https://repo1.maven.org/maven2/org/apache/camel/kafkaconnector/camel-ssh-kafka-connector/0.10.1/camel-ssh-kafka-connector-0.10.1-package.tar.gz -> untar.gz camel-ssh-kafka-connector-0.10.1-package.tar.gz +> wget https://repo1.maven.org/maven2/org/apache/camel/kafkaconnector/camel-ssh-kafka-connector/0.11.0/camel-ssh-kafka-connector-0.11.0-package.tar.gz +> untar.gz camel-ssh-kafka-connector-0.11.0-package.tar.gz ``` Now it's time to setup the connectors diff --git a/ssh/ssh-source/README.adoc b/ssh/ssh-source/README.adoc index 52b32f6..318ee52 100644 --- a/ssh/ssh-source/README.adoc +++ b/ssh/ssh-source/README.adoc @@ -45,7 +45,7 @@ and set the `plugin.path` property to your choosen location You'll need to build your connector starting from an archetype: ``` -> mvn archetype:generate -DarchetypeGroupId=org.apache.camel.kafkaconnector.archetypes -DarchetypeArtifactId=camel-kafka-connector-extensible-archetype -DarchetypeVersion=0.10.1 +> mvn archetype:generate -DarchetypeGroupId=org.apache.camel.kafkaconnector.archetypes -DarchetypeArtifactId=camel-kafka-connector-extensible-archetype -DarchetypeVersion=0.11.0 [INFO] Scanning for projects... [INFO] [INFO] ------------------< org.apache.maven:standalone-pom >------------------- @@ -59,34 +59,34 @@ You'll need to build your connector starting from an archetype: [INFO] [INFO] --- maven-archetype-plugin:3.1.2:generate (default-cli) @ standalone-pom --- [INFO] Generating project in Interactive mode -[INFO] Archetype repository not defined. Using the one from [org.apache.camel.kafkaconnector.archetypes:camel-kafka-connector-extensible-archetype:0.10.1] found in catalog remote +[INFO] Archetype repository not defined. Using the one from [org.apache.camel.kafkaconnector.archetypes:camel-kafka-connector-extensible-archetype:0.11.0] found in catalog remote Define value for property 'groupId': org.apache.camel.kafkaconnector Define value for property 'artifactId': ssh-extended -Define value for property 'version' 1.0-SNAPSHOT: : 0.10.1 +Define value for property 'version' 1.0-SNAPSHOT: : 0.11.0 Define value for property 'package' org.apache.camel.kafkaconnector: : Define value for property 'camel-kafka-connector-name': camel-ssh-kafka-connector -[INFO] Using property: camel-kafka-connector-version = 0.10.1 +[INFO] Using property: camel-kafka-connector-version = 0.11.0 Confirm properties configuration: groupId: org.apache.camel.kafkaconnector artifactId: ssh-extended -version: 0.10.1 +version: 0.11.0 package: com.github.oscerd camel-kafka-connector-name: camel-ssh-kafka-connector -camel-kafka-connector-version: 0.10.1 +camel-kafka-connector-version: 0.11.0 Y: : Y [INFO] ---------------------------------------------------------------------------- -[INFO] Using following parameters for creating project from Archetype: camel-kafka-connector-extensible-archetype:0.10.1 +[INFO] Using following parameters for creating project from Archetype: camel-kafka-connector-extensible-archetype:0.11.0 [INFO] ---------------------------------------------------------------------------- [INFO] Parameter: groupId, Value: org.apache.camel.kafkaconnector [INFO] Parameter: artifactId, Value: ssh-extended -[INFO] Parameter: version, Value: 0.10.1 +[INFO] Parameter: version, Value: 0.11.0 [INFO] Parameter: package, Value: org.apache.camel.kafkaconnector [INFO] Parameter: packageInPathFormat, Value: org/apache/camel/kafkaconnector [INFO] Parameter: package, Value: org.apache.camel.kafkaconnector -[INFO] Parameter: version, Value: 0.10.1 +[INFO] Parameter: version, Value: 0.11.0 [INFO] Parameter: groupId, Value: org.apache.camel.kafkaconnector [INFO] Parameter: camel-kafka-connector-name, Value: camel-ssh-kafka-connector -[INFO] Parameter: camel-kafka-connector-version, Value: 0.10.1 +[INFO] Parameter: camel-kafka-connector-version, Value: 0.11.0 [INFO] Parameter: artifactId, Value: ftps-extended [INFO] Project created from Archetype in dir: /home/workspace/miscellanea/ssh-extended [INFO] ------------------------------------------------------------------------ @@ -171,8 +171,8 @@ In this example we'll use `/home/oscerd/connectors/` as plugin.path, but we'll n ``` > cd /home/oscerd/connectors/ -> cp /home/workspace/miscellanea/ftps-extended/target/ssh-extended-0.10.1-package.tar.gz . -> untar.gz ssh-extended-0.10.1-package.tar.gz +> cp /home/workspace/miscellanea/ftps-extended/target/ssh-extended-0.11.0-package.tar.gz . +> untar.gz ssh-extended-0.11.0-package.tar.gz ``` Now it's time to setup the connectors diff --git a/telegram/telegram-sink/README.adoc b/telegram/telegram-sink/README.adoc index 9cda3d1..58b8ade 100644 --- a/telegram/telegram-sink/README.adoc +++ b/telegram/telegram-sink/README.adoc @@ -36,8 +36,8 @@ In this example we'll use `/home/oscerd/connectors/` ``` > cd /home/oscerd/connectors/ -> wget https://repo1.maven.org/maven2/org/apache/camel/kafkaconnector/camel-telegram-kafka-connector/0.10.1/camel-telegram-kafka-connector-0.10.1-package.tar.gz -> untar.gz camel-telegram-kafka-connector-0.10.1-package.tar.gz +> wget https://repo1.maven.org/maven2/org/apache/camel/kafkaconnector/camel-telegram-kafka-connector/0.11.0/camel-telegram-kafka-connector-0.11.0-package.tar.gz +> untar.gz camel-telegram-kafka-connector-0.11.0-package.tar.gz ``` Now it's time to setup the connectors @@ -145,8 +145,8 @@ So we need to do something like this: ``` > cd my-connectors/ -> wget https://repo1.maven.org/maven2/org/apache/camel/kafkaconnector/camel-telegram-kafka-connector/0.10.1/camel-telegram-kafka-connector-0.10.1-package.tar.gz -> untar.gz camel-telegram-kafka-connector-0.10.1-package.tar.gz +> wget https://repo1.maven.org/maven2/org/apache/camel/kafkaconnector/camel-telegram-kafka-connector/0.11.0/camel-telegram-kafka-connector-0.11.0-package.tar.gz +> untar.gz camel-telegram-kafka-connector-0.11.0-package.tar.gz ``` Now we can start the build @@ -171,7 +171,7 @@ You should see something like this: [source,json,options="nowrap"] ---- -[{"class":"org.apache.camel.kafkaconnector.CamelSinkConnector","type":"sink","version":"0.10.1"},{"class":"org.apache.camel.kafkaconnector.CamelSourceConnector","type":"source","version":"0.10.1"},{"class":"org.apache.camel.kafkaconnector.telegram.CamelTelegramSinkConnector","type":"sink","version":"0.10.1"},{"class":"org.apache.camel.kafkaconnector.telegram.CamelTelegramSourceConnector","type":"source","version":"0.10.1"},{"class":"org.apache.kafka.connect.file.FileStreamSinkConnector", [...] +[{"class":"org.apache.camel.kafkaconnector.CamelSinkConnector","type":"sink","version":"0.11.0"},{"class":"org.apache.camel.kafkaconnector.CamelSourceConnector","type":"source","version":"0.11.0"},{"class":"org.apache.camel.kafkaconnector.telegram.CamelTelegramSinkConnector","type":"sink","version":"0.11.0"},{"class":"org.apache.camel.kafkaconnector.telegram.CamelTelegramSourceConnector","type":"source","version":"0.11.0"},{"class":"org.apache.kafka.connect.file.FileStreamSinkConnector", [...] ---- ### Set the AWS credential as secret (optional) diff --git a/telegram/telegram-source/README.adoc b/telegram/telegram-source/README.adoc index be64802..3dc402f 100644 --- a/telegram/telegram-source/README.adoc +++ b/telegram/telegram-source/README.adoc @@ -32,8 +32,8 @@ In this example we'll use `/home/oscerd/connectors/` ``` > cd /home/oscerd/connectors/ -> wget https://repo1.maven.org/maven2/org/apache/camel/kafkaconnector/camel-telegram-kafka-connector/0.10.1/camel-telegram-kafka-connector-0.10.1-package.tar.gz -> untar.gz camel-telegram-kafka-connector-0.10.1-package.tar.gz +> wget https://repo1.maven.org/maven2/org/apache/camel/kafkaconnector/camel-telegram-kafka-connector/0.11.0/camel-telegram-kafka-connector-0.11.0-package.tar.gz +> untar.gz camel-telegram-kafka-connector-0.11.0-package.tar.gz ``` Now it's time to setup the connectors @@ -140,8 +140,8 @@ So we need to do something like this: ``` > cd my-connectors/ -> wget https://repo1.maven.org/maven2/org/apache/camel/kafkaconnector/camel-telegram-kafka-connector/0.10.1/camel-telegram-kafka-connector-0.10.1-package.tar.gz -> untar.gz camel-telegram-kafka-connector-0.10.1-package.tar.gz +> wget https://repo1.maven.org/maven2/org/apache/camel/kafkaconnector/camel-telegram-kafka-connector/0.11.0/camel-telegram-kafka-connector-0.11.0-package.tar.gz +> untar.gz camel-telegram-kafka-connector-0.11.0-package.tar.gz ``` Now we can start the build @@ -166,7 +166,7 @@ You should see something like this: [source,json,options="nowrap"] ---- -[{"class":"org.apache.camel.kafkaconnector.CamelSinkConnector","type":"sink","version":"0.10.1"},{"class":"org.apache.camel.kafkaconnector.CamelSourceConnector","type":"source","version":"0.10.1"},{"class":"org.apache.camel.kafkaconnector.slack.CamelTelegramSinkConnector","type":"sink","version":"0.10.1"},{"class":"org.apache.camel.kafkaconnector.slack.CamelTelegramSourceConnector","type":"source","version":"0.10.1"},{"class":"org.apache.kafka.connect.file.FileStreamSinkConnector","type" [...] +[{"class":"org.apache.camel.kafkaconnector.CamelSinkConnector","type":"sink","version":"0.11.0"},{"class":"org.apache.camel.kafkaconnector.CamelSourceConnector","type":"source","version":"0.11.0"},{"class":"org.apache.camel.kafkaconnector.slack.CamelTelegramSinkConnector","type":"sink","version":"0.11.0"},{"class":"org.apache.camel.kafkaconnector.slack.CamelTelegramSourceConnector","type":"source","version":"0.11.0"},{"class":"org.apache.kafka.connect.file.FileStreamSinkConnector","type" [...] ---- ### Set the Authorization Token as secret (optional) diff --git a/twitter/twitter-direct-message-sink/README.adoc b/twitter/twitter-direct-message-sink/README.adoc index 51e7358..79938b5 100644 --- a/twitter/twitter-direct-message-sink/README.adoc +++ b/twitter/twitter-direct-message-sink/README.adoc @@ -32,8 +32,8 @@ In this example we'll use `/home/oscerd/connectors/` ``` > cd /home/oscerd/connectors/ -> wget https://repo1.maven.org/maven2/org/apache/camel/kafkaconnector/camel-twitter-directmessage-kafka-connector/0.10.1/camel-twitter-directmessage-kafka-connector-0.10.1-package.tar.gz -> untar.gz camel-twitter-directmessage-kafka-connector-0.10.1-package.tar.gz +> wget https://repo1.maven.org/maven2/org/apache/camel/kafkaconnector/camel-twitter-directmessage-kafka-connector/0.11.0/camel-twitter-directmessage-kafka-connector-0.11.0-package.tar.gz +> untar.gz camel-twitter-directmessage-kafka-connector-0.11.0-package.tar.gz ``` Now it's time to setup the connectors diff --git a/twitter/twitter-direct-message-source/README.adoc b/twitter/twitter-direct-message-source/README.adoc index c045719..c8ffa78 100644 --- a/twitter/twitter-direct-message-source/README.adoc +++ b/twitter/twitter-direct-message-source/README.adoc @@ -32,8 +32,8 @@ In this example we'll use `/home/oscerd/connectors/` ``` > cd /home/oscerd/connectors/ -> wget https://repo1.maven.org/maven2/org/apache/camel/kafkaconnector/camel-twitter-directmessage-kafka-connector/0.10.1/camel-twitter-directmessage-kafka-connector-0.10.1-package.tar.gz -> untar.gz camel-twitter-directmessage-kafka-connector-0.10.1-package.tar.gz +> wget https://repo1.maven.org/maven2/org/apache/camel/kafkaconnector/camel-twitter-directmessage-kafka-connector/0.11.0/camel-twitter-directmessage-kafka-connector-0.11.0-package.tar.gz +> untar.gz camel-twitter-directmessage-kafka-connector-0.11.0-package.tar.gz ``` Now it's time to setup the connectors diff --git a/twitter/twitter-search-source/README.adoc b/twitter/twitter-search-source/README.adoc index 533dc4b..d98f3ec 100644 --- a/twitter/twitter-search-source/README.adoc +++ b/twitter/twitter-search-source/README.adoc @@ -32,8 +32,8 @@ In this example we'll use `/home/oscerd/connectors/` ``` > cd /home/oscerd/connectors/ -> wget https://repo1.maven.org/maven2/org/apache/camel/kafkaconnector/camel-twitter-search-kafka-connector/0.10.1/camel-twitter-search-kafka-connector-0.10.1-package.tar.gz -> untar.gz camel-twitter-search-kafka-connector-0.10.1-package.tar.gz +> wget https://repo1.maven.org/maven2/org/apache/camel/kafkaconnector/camel-twitter-search-kafka-connector/0.11.0/camel-twitter-search-kafka-connector-0.11.0-package.tar.gz +> untar.gz camel-twitter-search-kafka-connector-0.11.0-package.tar.gz ``` Now it's time to setup the connectors diff --git a/twitter/twitter-timeline-sink/README.adoc b/twitter/twitter-timeline-sink/README.adoc index d83f0f2..972151a 100644 --- a/twitter/twitter-timeline-sink/README.adoc +++ b/twitter/twitter-timeline-sink/README.adoc @@ -34,8 +34,8 @@ In this example we'll use `/home/oscerd/connectors/` [source] ---- > cd /home/oscerd/connectors/ -> wget https://repo1.maven.org/maven2/org/apache/camel/kafkaconnector/camel-twitter-timeline-kafka-connector/0.10.1/camel-twitter-timeline-kafka-connector-0.10.1-package.tar.gz -> untar.gz camel-twitter-timeline-kafka-connector-0.10.1-package.tar.gz +> wget https://repo1.maven.org/maven2/org/apache/camel/kafkaconnector/camel-twitter-timeline-kafka-connector/0.11.0/camel-twitter-timeline-kafka-connector-0.11.0-package.tar.gz +> untar.gz camel-twitter-timeline-kafka-connector-0.11.0-package.tar.gz ---- Now it's time to setup the connectors diff --git a/twitter/twitter-timeline-source/README.adoc b/twitter/twitter-timeline-source/README.adoc index 7e8d7b7..6e30e61 100644 --- a/twitter/twitter-timeline-source/README.adoc +++ b/twitter/twitter-timeline-source/README.adoc @@ -34,8 +34,8 @@ In this example we'll use `/home/oscerd/connectors/` [source] ---- > cd /home/oscerd/connectors/ -> wget https://repo1.maven.org/maven2/org/apache/camel/kafkaconnector/camel-twitter-timeline-kafka-connector/0.10.1/camel-twitter-timeline-kafka-connector-0.10.1-package.tar.gz -> untar.gz camel-twitter-timeline-kafka-connector-0.10.1-package.tar.gz +> wget https://repo1.maven.org/maven2/org/apache/camel/kafkaconnector/camel-twitter-timeline-kafka-connector/0.11.0/camel-twitter-timeline-kafka-connector-0.11.0-package.tar.gz +> untar.gz camel-twitter-timeline-kafka-connector-0.11.0-package.tar.gz ---- Now it's time to setup the connectors @@ -75,6 +75,6 @@ In another terminal, using kafkacat, you can consume the messages ---- > ./kafkacat -b localhost:9092 -t mytopic % Auto-selecting Consumer mode (use -P or -C to override) -StatusJSONImpl{createdAt=Thu Jan 21 19:40:53 UTC 2021, id=1352340411239559170, text='We released Apache Camel 3.7.1 (LTS) today, a new patch release with 29 fixes and improvements: https://t.co/osOTD4uY5k #apachecamel', source='<a href="https://about.twitter.com/products/tweetdeck"; rel="nofollow">TweetDeck</a>', isTruncated=false, inReplyToStatusId=-1, inReplyToUserId=-1, isFavorited=false, isRetweeted=false, favoriteCount=37, inReplyToScreenName='null', geoLocation=null, place=null, ret [...] +StatusJSONImpl{createdAt=Thu Jan 21 19:40:53 UTC 2021, id=1352340411239559170, text='We released Apache Camel 3.7.1 (LTS) today, a new patch release with 29 fixes and improvements: https://t.co/osOTD4uY5k #apachecamel', source='<a href="https://about.twitter.com/products/tweetdeck"; rel="nofollow">TweetDeck</a>', isTruncated=false, inReplyToStatusId=-1, inReplyToUserId=-1, isFavorited=false, isRetweeted=false, favoriteCount=37, inReplyToScreenName='null', geoLocation=null, place=null, ret [...] % Reached end of topic mytopic [0] at offset 1 ----
