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