This is an automated email from the ASF dual-hosted git repository.
valdar pushed a change to branch camel-master
in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git.
from cc49c17 [create-pull-request] automated change
new f315719 fixed #980 : camel.source.contentLogLevel config not honored
in source connectors
new dff4d98 Fixed flaky hdfs itest.
new ef0eb99 Properly handling UnitOfWork by compelting it at the last
possible moment, properly fix #202
new 290f065 fix #969 : Convert NettyChannelBufferStreamCache from
NettyHttpSource not converted to string.
new 99f11df Fixed itest for netty-http.
new c962725 chore: fix checkstyle.
new 3861245 Some folowup improvements fro #969 and #202.
new e806401 Adjusted catalog tests for camel 3.9.0
new a85a209 chore: regen
The 9 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:
.../resources/connectors/camel-aws2-s3-sink.json | 4 +-
.../resources/connectors/camel-aws2-s3-source.json | 4 +-
.../resources/connectors/camel-aws2-sns-sink.json | 4 +-
.../resources/connectors/camel-aws2-sqs-sink.json | 4 +-
.../connectors/camel-aws2-sqs-source.json | 4 +-
.../connectors/camel-netty-http-sink.json | 14 +++
.../connectors/camel-netty-http-source.json | 14 +++
.../resources/connectors/camel-netty-sink.json | 14 +++
.../resources/connectors/camel-netty-source.json | 14 +++
.../connectors/camel-spring-rabbitmq-source.json | 47 ++++++++
.../catalog/CamelKafkaConnectorCatalogTest.java | 2 +-
.../generated/resources/camel-aws2-s3-sink.json | 4 +-
.../generated/resources/camel-aws2-s3-source.json | 4 +-
.../docs/camel-aws2-s3-kafka-sink-connector.adoc | 4 +-
.../docs/camel-aws2-s3-kafka-source-connector.adoc | 4 +-
.../aws2s3/CamelAws2s3SinkConnectorConfig.java | 4 +-
.../aws2s3/CamelAws2s3SourceConnectorConfig.java | 4 +-
.../generated/resources/camel-aws2-sns-sink.json | 4 +-
.../docs/camel-aws2-sns-kafka-sink-connector.adoc | 4 +-
.../aws2sns/CamelAws2snsSinkConnectorConfig.java | 4 +-
.../generated/resources/camel-aws2-sqs-sink.json | 4 +-
.../generated/resources/camel-aws2-sqs-source.json | 4 +-
.../docs/camel-aws2-sqs-kafka-sink-connector.adoc | 4 +-
.../camel-aws2-sqs-kafka-source-connector.adoc | 4 +-
.../aws2sqs/CamelAws2sqsSinkConnectorConfig.java | 4 +-
.../aws2sqs/CamelAws2sqsSourceConnectorConfig.java | 4 +-
.../generated/resources/camel-netty-http-sink.json | 14 +++
.../resources/camel-netty-http-source.json | 14 +++
.../camel-netty-http-kafka-sink-connector.adoc | 4 +-
.../camel-netty-http-kafka-source-connector.adoc | 4 +-
.../CamelNettyhttpSinkConnectorConfig.java | 8 ++
.../CamelNettyhttpSourceConnectorConfig.java | 8 ++
.../src/generated/resources/camel-netty-sink.json | 14 +++
.../generated/resources/camel-netty-source.json | 14 +++
.../docs/camel-netty-kafka-sink-connector.adoc | 4 +-
.../docs/camel-netty-kafka-source-connector.adoc | 4 +-
.../netty/CamelNettySinkConnectorConfig.java | 8 ++
.../netty/CamelNettySourceConnectorConfig.java | 8 ++
.../resources/camel-spring-rabbitmq-source.json | 47 ++++++++
...mel-spring-rabbitmq-kafka-source-connector.adoc | 8 +-
.../CamelSpringrabbitmqSourceConnectorConfig.java | 24 +++++
core/pom.xml | 19 +++-
.../apache/camel/kafkaconnector/CamelSinkTask.java | 14 ++-
.../kafkaconnector/CamelSourceConnectorConfig.java | 5 +
.../camel/kafkaconnector/CamelSourceRecord.java | 59 ++++++++++
.../camel/kafkaconnector/CamelSourceTask.java | 99 +++++++++++++----
.../camel/kafkaconnector/CamelSinkTaskTest.java | 13 +++
.../camel/kafkaconnector/CamelSourceTaskTest.java | 62 +++++++++++
.../CamelTypeConverterTransformTest.java | 24 +++++
docs/modules/ROOT/nav.adoc | 50 +++++++++
docs/modules/ROOT/pages/connectors.adoc | 24 ++++-
.../camel-aws2-s3-kafka-sink-connector.adoc | 4 +-
.../camel-aws2-s3-kafka-source-connector.adoc | 4 +-
.../camel-aws2-sns-kafka-sink-connector.adoc | 4 +-
.../camel-aws2-sqs-kafka-sink-connector.adoc | 4 +-
.../camel-aws2-sqs-kafka-source-connector.adoc | 4 +-
.../camel-netty-http-kafka-sink-connector.adoc | 4 +-
.../camel-netty-http-kafka-source-connector.adoc | 4 +-
.../camel-netty-kafka-sink-connector.adoc | 4 +-
.../camel-netty-kafka-source-connector.adoc | 4 +-
...mel-spring-rabbitmq-kafka-source-connector.adoc | 8 +-
parent/pom.xml | 9 ++
.../hdfs/sink/CamelSinkHDFSITCase.java | 19 ++--
.../camel/kafkaconnector/hdfs/utils/HDFSEasy.java | 26 ++++-
tests/{itests-sql => itests-netty-http}/pom.xml | 27 ++---
.../nettyhttp/sink/CamelSinkNettyhttpITCase.java} | 71 ++++++------
.../source/CamelNettyHTTPPropertyFactory.java} | 41 ++++---
.../source/CamelSourceNettyHTTPITCase.java | 119 +++++++++++++++++++++
68 files changed, 927 insertions(+), 166 deletions(-)
create mode 100644
core/src/main/java/org/apache/camel/kafkaconnector/CamelSourceRecord.java
copy tests/{itests-sql => itests-netty-http}/pom.xml (81%)
copy
tests/{itests-netty/src/test/java/org/apache/camel/kafkaconnector/netty/sink/CamelSinkNettyITCase.java
=>
itests-netty-http/src/test/java/org/apache/camel/kafkaconnector/nettyhttp/sink/CamelSinkNettyhttpITCase.java}
(60%)
copy
tests/{itests-syslog/src/test/java/org/apache/camel/kafkaconnector/syslog/source/CamelSyslogPropertyFactory.java
=>
itests-netty-http/src/test/java/org/apache/camel/kafkaconnector/nettyhttp/source/CamelNettyHTTPPropertyFactory.java}
(51%)
create mode 100644
tests/itests-netty-http/src/test/java/org/apache/camel/kafkaconnector/nettyhttp/source/CamelSourceNettyHTTPITCase.java
