This is an automated email from the ASF dual-hosted git repository.
valdar pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git.
from d9fcbc5 Merge pull request #213 from apache/Testcontainers-1.14.2
new f559af6 Fixed a problem where the same Exchange was used multiple
times.
new db0c4e3 Added a Burn In run script for tests/ module.
new 66adc19 Added camel-syslog-kafka-connector fix #145
new 732c213 chore: doc regen.
new 71d3073 Added itests for camel-syslog-kafka-connector fix #145
new 48b15cf Merge pull request #214 from valdar/syslogConnector
The 431 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:
.../pom.xml | 18 +--
.../src/main/assembly/package.xml | 0
.../docs/camel-syslog-kafka-sink-connector.adoc | 27 +++++
.../docs/camel-syslog-kafka-source-connector.adoc | 27 +++++
.../syslog/CamelSyslogSinkConnector.java} | 12 +-
.../syslog/CamelSyslogSinkConnectorConfig.java} | 28 +++--
.../syslog/CamelSyslogSinkTask.java} | 21 ++--
.../syslog/CamelSyslogSourceConnector.java} | 11 +-
.../syslog/CamelSyslogSourceConnectorConfig.java} | 30 +++--
.../syslog/CamelSyslogSourceTask.java} | 20 ++--
.../src/main/resources/META-INF/LICENSE.txt | 0
.../src/main/resources/META-INF/NOTICE.txt | 0
connectors/pom.xml | 1 +
.../apache/camel/kafkaconnector/CamelSinkTask.java | 4 +-
docs/modules/ROOT/pages/connectors.adoc | 6 +-
tests/pom.xml | 6 +
.../camel/kafkaconnector/PluginPathHelper.java | 2 +-
.../kafkaconnect/KafkaConnectEmbedded.java | 21 ++--
.../kafkaconnect/KafkaConnectRunnerService.java | 2 +-
.../services/kafkaconnect/KafkaConnectService.java | 2 +-
.../services/syslog/SyslogService.java | 62 ++++++++++
.../sink/aws/sqs/CamelSinkAWSSQSITCase.java | 2 +-
.../sink/syslog/CamelSinkSyslogITCase.java | 88 ++++++++++++++
.../CamelSyslogPropertyFactory.java} | 31 ++---
.../aws/kinesis/CamelSourceAWSKinesisITCase.java | 2 +-
.../source/syslog/CamelSourceSyslogITCase.java | 127 +++++++++++++++++++++
.../CamelSyslogPropertyFactory.java} | 37 +++---
.../camel/kafkaconnector/utils/NetworkUtils.java | 82 +++++++++++++
tests/src/test/resources/log4j2.properties | 2 +-
{core => tests}/testBurnInRun.sh | 3 +-
30 files changed, 560 insertions(+), 114 deletions(-)
copy connectors/{camel-sjms2-kafka-connector =>
camel-syslog-kafka-connector}/pom.xml (92%)
copy connectors/{camel-zookeeper-master-kafka-connector =>
camel-syslog-kafka-connector}/src/main/assembly/package.xml (100%)
create mode 100644
connectors/camel-syslog-kafka-connector/src/main/docs/camel-syslog-kafka-sink-connector.adoc
create mode 100644
connectors/camel-syslog-kafka-connector/src/main/docs/camel-syslog-kafka-source-connector.adoc
copy
connectors/{camel-vm-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/vm/CamelVmSinkConnector.java
=>
camel-syslog-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/syslog/CamelSyslogSinkConnector.java}
(69%)
copy
connectors/{camel-amqp-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/amqp/CamelAmqpSinkConnector.java
=>
camel-syslog-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/syslog/CamelSyslogSinkConnectorConfig.java}
(58%)
copy
connectors/{camel-atomix-multimap-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/atomixmultimap/CamelAtomixmultimapSinkTask.java
=>
camel-syslog-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/syslog/CamelSyslogSinkTask.java}
(56%)
copy
connectors/{camel-vm-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/vm/CamelVmSourceConnector.java
=>
camel-syslog-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/syslog/CamelSyslogSourceConnector.java}
(73%)
copy
connectors/{camel-amqp-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/amqp/CamelAmqpSinkConnector.java
=>
camel-syslog-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/syslog/CamelSyslogSourceConnectorConfig.java}
(57%)
copy
connectors/{camel-atomix-queue-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/atomixqueue/CamelAtomixqueueSourceTask.java
=>
camel-syslog-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/syslog/CamelSyslogSourceTask.java}
(58%)
copy {tooling/camel-kafka-connector-docs-maven-plugin =>
connectors/camel-syslog-kafka-connector}/src/main/resources/META-INF/LICENSE.txt
(100%)
copy {tooling/camel-kafka-connector-docs-maven-plugin =>
connectors/camel-syslog-kafka-connector}/src/main/resources/META-INF/NOTICE.txt
(100%)
create mode 100644
tests/src/test/java/org/apache/camel/kafkaconnector/services/syslog/SyslogService.java
create mode 100644
tests/src/test/java/org/apache/camel/kafkaconnector/sink/syslog/CamelSinkSyslogITCase.java
copy
tests/src/test/java/org/apache/camel/kafkaconnector/sink/{http/CamelHTTPPropertyFactory.java
=> syslog/CamelSyslogPropertyFactory.java} (57%)
create mode 100644
tests/src/test/java/org/apache/camel/kafkaconnector/source/syslog/CamelSourceSyslogITCase.java
copy
tests/src/test/java/org/apache/camel/kafkaconnector/source/{jms/CamelJMSPropertyFactory.java
=> syslog/CamelSyslogPropertyFactory.java} (56%)
create mode 100644
tests/src/test/java/org/apache/camel/kafkaconnector/utils/NetworkUtils.java
copy {core => tests}/testBurnInRun.sh (84%)
