You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by gi...@apache.org on 2020/11/27 03:36:23 UTC
[camel-kafka-connector] branch automatic-periodic-sync updated
(d29d32a -> bd78396)
This is an automated email from the ASF dual-hosted git repository.
github-bot pushed a change to branch automatic-periodic-sync
in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git.
omit d29d32a [create-pull-request] automated change
omit 7602236 Fixed catalog test with JDK11
omit dd12724 Regen
omit 363edca Fixed Test and regen
omit 672cbec Regen and fixed compilation
omit 270d806 fixed #715: Create the sink counterpart of the PojoToSchemaAndStructTransform.
omit d43b657 related to #715: renamed PojoToSchemaAndStructTransform to SourcePojoToSchemaAndStructTransform
omit 81c2f32 Fixed wrong config references in both CamelSinkTask and CamelSourceTask
omit b5bf4a5 Prevent NPEs in the (unlikely) case the record value is null
omit 85f54c3 Added documentation for idempotency in basic configuration docs
omit f6b983b Fixed CS
omit 032c271 Added Support for KafkaIdempotentRepository
omit 1b7003f Fixed CS
omit 741873a Idempotency: Lets build the idempotentRepository before and use a reference to it in registry
omit 922a823 Use the errorHandler variable coming from Builder
omit bbed72c Fixed CS
omit 5465d13 Added Memory Idempotency support for both sink and source
omit 09491aa fix #692 : Cache already computed Schemas in PojoToSchemaAndStructTransform.
omit 8d26827 Enanched unit tests for PojoToSchemaAndStructTransform
omit 4bee264 Fixed CamelKafkaConnectorCatalogTest
omit cb48e11 Camel-kafka-connector-catalog: Avoid to check for number of options on camel-master
omit 5ab5966 Updated AWS test services according to interface changes from camel 3.7
omit cf7c29c Regen
omit 84bb9d0 File language and core languages in general are not working
omit 5a52740 Camel-Master: Fix catalog test
omit 27cf417 Fix couchbase catalog test
omit f50dd54 Fixed incorrect formatting of Bucket URL in Couchbase tests
omit 83870a0 Aligned camel-master tests with fix
omit 8f5add8 Adjust the emdedded Kafka service to the updated interface from Camel 3.7
omit 66c3884 Catalog tests fixed
omit 945bf81 Camel-Master: Fixed catalog test for aws2-sns
omit b2064ac [create-pull-request] automated change
omit b9b4594 [create-pull-request] automated change
omit 4c6ff46 Temporarily disable a test affected by CAMEL-15789
omit c3b2a9a Point to 3.7.0-SNAPSHOT
add f6c340b Updated CHANGELOG.md
add fc01b43 Enanched unit tests for PojoToSchemaAndStructTransform
add a27015c fix #692 : Cache already computed Schemas in PojoToSchemaAndStructTransform.
add 897516d Added Memory Idempotency support for both sink and source
add 9d4ca04 Fixed CS
add 7b1d2dd Updated CHANGELOG.md
add ac17d29 Use the errorHandler variable coming from Builder
add 835f83f Updated CHANGELOG.md
add ab9f9b1 Idempotency: Lets build the idempotentRepository before and use a reference to it in registry
add 1c4d16c Fixed CS
add d6b7a1b Added Support for KafkaIdempotentRepository
add 3b2c306 Fixed CS
add 3d54143 Updated CHANGELOG.md
add 3344f51 Added documentation for idempotency in basic configuration docs
add 60897bb Prevent NPEs in the (unlikely) case the record value is null
add dc7ca4d Fixed wrong config references in both CamelSinkTask and CamelSourceTask
add 861463c Updated CHANGELOG.md
add f6badac Updated CHANGELOG.md
add 2384af5 Updated CHANGELOG.md
add 58e0d6e related to #715: renamed PojoToSchemaAndStructTransform to SourcePojoToSchemaAndStructTransform
add d99e233 fixed #715: Create the sink counterpart of the PojoToSchemaAndStructTransform.
add 05573e4 Updated CHANGELOG.md
add fc1dd52 Updated CHANGELOG.md
add a2d437b Added Integration tests for Camel-Ssh-Kafka-Connector
add c06f24b Added Integration test for Camel-Ssh-Kafka-connector to modules
add f592c63 Fixed Commons-io dependency version in ssh IT test
add d147fc3 Move SshTransforms from example/it test class directly in the camel-ssh-kafka-connector
add 809b8a8 Move SshTransforms from example/it test class directly in the camel-ssh-kafka-connector, removed the transforms from itest
add 77eb2aa Itest SSH: Commons-io is needed in it test
add f1b58ec fix #738 : added timestamp information to source records.
add 774d7ea Point to 3.7.0-SNAPSHOT
add b9bb995 Temporarily disable a test affected by CAMEL-15789
add bde443f [create-pull-request] automated change
add 985225f [create-pull-request] automated change
add f9b99d0 Camel-Master: Fixed catalog test for aws2-sns
add 5f26c39 Catalog tests fixed
add c448149 Adjust the emdedded Kafka service to the updated interface from Camel 3.7
add a6905a0 Aligned camel-master tests with fix
add f19d1c7 Fixed incorrect formatting of Bucket URL in Couchbase tests
add 3ad7252 Fix couchbase catalog test
add 4546e0f Camel-Master: Fix catalog test
add ff76315 File language and core languages in general are not working
add a3258fb Regen
add f52913f Updated AWS test services according to interface changes from camel 3.7
add 6197ea6 Camel-kafka-connector-catalog: Avoid to check for number of options on camel-master
add 771772b Fixed CamelKafkaConnectorCatalogTest
add 42ae769 Regen and fixed compilation
add 35d96ae Fixed Test and regen
add 7a0cba2 Regen
add 1b596a4 Fixed catalog test with JDK11
add bd78396 [create-pull-request] automated change
This update added new revisions after undoing existing revisions.
That is to say, some revisions that were in the old version of the
branch are not in the new version. This situation occurs
when a user --force pushes a change and generates a repository
containing something like this:
* -- * -- B -- O -- O -- O (d29d32a)
\
N -- N -- N refs/heads/automatic-periodic-sync (bd78396)
You should already have received notification emails for all of the O
revisions, and so the following emails describe only the N revisions
from the common base, B.
Any revisions marked "omit" are not gone; other references still
refer to them. Any revisions marked "discard" are gone forever.
No new revisions were added by this update.
Summary of changes:
CHANGELOG.md | 19 +++++
.../resources/connectors/camel-ssh-sink.json | 5 +-
.../resources/connectors/camel-ssh-source.json | 5 +-
connectors/camel-ssh-kafka-connector/pom.xml | 5 ++
.../src/generated/resources/camel-ssh-sink.json | 5 +-
.../src/generated/resources/camel-ssh-source.json | 5 +-
.../main/docs/camel-ssh-kafka-sink-connector.adoc | 9 ++-
.../docs/camel-ssh-kafka-source-connector.adoc | 9 ++-
.../ssh/transformers/SshTransforms.java} | 35 +++++----
.../kafkaconnector/timer/CamelTimerSourceTask.java | 22 +++++-
.../camel/kafkaconnector/CamelSourceTask.java | 10 ++-
.../camel/kafkaconnector/CamelSourceTaskTest.java | 2 +
.../connectors/camel-ssh-kafka-sink-connector.adoc | 9 ++-
.../camel-ssh-kafka-source-connector.adoc | 9 ++-
tests/{itests-rabbitmq => itests-ssh}/pom.xml | 19 ++---
.../kafkaconnector/ssh/services/SshContainer.java} | 22 +++---
.../ssh/services/SshLocalContainerService.java} | 29 ++++---
.../ssh/services/SshRemoteService.java} | 22 +++---
.../kafkaconnector/ssh/services/SshService.java} | 15 ++--
.../ssh/services/SshServiceFactory.java} | 20 ++---
.../ssh/sink/CamelSinkSshITCase.java} | 90 +++-------------------
.../ssh/sink/CamelSshPropertyFactory.java | 49 ++++++++++++
.../ssh/source/CamelSourceSshITCase.java} | 66 ++++++----------
.../ssh/source/CamelSshPropertyFactory.java | 56 ++++++++++++++
tests/pom.xml | 1 +
25 files changed, 322 insertions(+), 216 deletions(-)
copy connectors/{camel-ftps-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/ftps/transformers/FtpsRemoteFileTransforms.java => camel-ssh-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/ssh/transformers/SshTransforms.java} (56%)
copy tests/{itests-rabbitmq => itests-ssh}/pom.xml (84%)
copy tests/{itests-cassandra/src/test/java/org/apache/camel/kafkaconnector/cassandra/services/CassandraContainer.java => itests-ssh/src/test/java/org/apache/camel/kafkaconnector/ssh/services/SshContainer.java} (67%)
copy tests/{itests-cassandra/src/test/java/org/apache/camel/kafkaconnector/cassandra/services/CassandraLocalContainerService.java => itests-ssh/src/test/java/org/apache/camel/kafkaconnector/ssh/services/SshLocalContainerService.java} (58%)
copy tests/{itests-hdfs/src/test/java/org/apache/camel/kafkaconnector/hdfs/services/RemoteHDFSService.java => itests-ssh/src/test/java/org/apache/camel/kafkaconnector/ssh/services/SshRemoteService.java} (74%)
copy tests/{itests-aws-common/src/test/java/org/apache/camel/kafkaconnector/aws/common/services/AWSService.java => itests-ssh/src/test/java/org/apache/camel/kafkaconnector/ssh/services/SshService.java} (83%)
copy tests/{itests-rabbitmq/src/test/java/org/apache/camel/kafkaconnector/rabbitmq/services/RabbitMQServiceFactory.java => itests-ssh/src/test/java/org/apache/camel/kafkaconnector/ssh/services/SshServiceFactory.java} (62%)
copy tests/{itests-cassandra/src/test/java/org/apache/camel/kafkaconnector/cassandra/sink/CamelSinkCassandraITCase.java => itests-ssh/src/test/java/org/apache/camel/kafkaconnector/ssh/sink/CamelSinkSshITCase.java} (51%)
create mode 100644 tests/itests-ssh/src/test/java/org/apache/camel/kafkaconnector/ssh/sink/CamelSshPropertyFactory.java
copy tests/{itests-timer/src/test/java/org/apache/camel/kafkaconnector/timer/source/CamelSourceTimerITCase.java => itests-ssh/src/test/java/org/apache/camel/kafkaconnector/ssh/source/CamelSourceSshITCase.java} (55%)
create mode 100644 tests/itests-ssh/src/test/java/org/apache/camel/kafkaconnector/ssh/source/CamelSshPropertyFactory.java