This is an automated email from the ASF dual-hosted git repository.
orpiske pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git.
from 7502299 Remove Github changelog action
new f9a3e56 Fixed incorrect number of arguments in HDFS test logs
new 18f5869 Removed invalid throws in RabbitMQ test client code
new 6d2493c Fixed invalid usage of raw types
new df27d6f Removed declarations of exceptions never thrown
new d65aa45 Removed unnecessary string scaping in test logs
new e886eab Simplified assertion in the elastic search sink test
new bfa8e7c Do fail the AWS S3 test on I/O error while reading the files
new e52aba2 Force the embedded runner to throw an exception if the
provided service is null
new 99214cf Add an warning if the embedded runner times out before fully
stopped
new b9d85de Use a final variable for test connector properties
new ffedadd Cleanup iteration over test result set
new 03f9486 Use the StandardsCharset to avoid the
UnsupportedEncodingException
new bddecd6 Use the join method to simplify building the plugin paths
new 75110df Use a immutable singleton list instead in the test KafkaClient
The 14 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.../aws/v2/s3/source/CamelSourceAWSS3ITCase.java | 11 ++++++++++-
.../blob/sink/CamelSinkAzureStorageBlobITCase.java | 4 ++--
.../queue/sink/CamelSinkAzureStorageQueueITCase.java | 2 +-
.../common/BasicConnectorPropertyFactory.java | 2 +-
.../kafkaconnector/common/PluginPathHelper.java | 2 +-
.../common/clients/kafka/KafkaClient.java | 5 ++---
.../common/services/kafka/EmbeddedKafkaService.java | 4 ++--
.../services/kafkaconnect/KafkaConnectRunner.java | 2 +-
.../kafkaconnect/KafkaConnectRunnerService.java | 6 ++++--
.../services/kafkaconnect/KafkaConnectService.java | 4 ++--
.../sink/CamelSinkElasticSearchITCase.java | 2 +-
.../hdfs/sink/CamelSinkHDFSITCase.java | 4 ++--
.../kafkaconnector/jdbc/client/DatabaseClient.java | 2 +-
.../jdbc/sink/CamelSinkJDBCITCase.java | 2 +-
.../jdbc/sink/CamelSinkJDBCNoDataSourceITCase.java | 2 +-
.../mongodb/sink/CamelSinkMongoDBITCase.java | 2 +-
.../rabbitmq/clients/RabbitMQClient.java | 2 --
.../rabbitmq/sink/RabbitMQSinkITCase.java | 20 +++++++-------------
.../kafkaconnector/sql/client/DatabaseClient.java | 2 +-
.../kafkaconnector/sql/sink/CamelSinkSQLITCase.java | 2 +-
.../sql/source/CamelSourceSQLITCase.java | 2 +-
.../kafkaconnector/ssh/services/SshService.java | 4 ++--
.../syslog/services/SyslogService.java | 4 ++--
.../syslog/source/CamelSourceSyslogITCase.java | 4 ++--
24 files changed, 49 insertions(+), 47 deletions(-)