This is an automated email from the ASF dual-hosted git repository.
acosentino pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git.
from 744e903 Updated CHANGELOG.md
new 42456d6 Fixed flaky hdfs itest.
new 2a1a507 Properly handling UnitOfWork by compelting it at the last
possible moment, properly fix #202
new 63ef1f0 fix #969 : Convert NettyChannelBufferStreamCache from
NettyHttpSource not converted to string.
new f6a3e04 Fixed itest for netty-http.
new 98f6ffb chore: fix checkstyle.
The 5 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:
core/pom.xml | 19 +++-
.../kafkaconnector/CamelSourceConnectorConfig.java | 5 +
.../camel/kafkaconnector/CamelSourceRecord.java | 59 ++++++++++
.../camel/kafkaconnector/CamelSourceTask.java | 82 +++++++++++---
.../camel/kafkaconnector/CamelSourceTaskTest.java | 48 +++++++++
.../CamelTypeConverterTransformTest.java | 24 +++++
parent/pom.xml | 8 +-
.../hdfs/sink/CamelSinkHDFSITCase.java | 19 ++--
.../camel/kafkaconnector/hdfs/utils/HDFSEasy.java | 26 ++++-
tests/itests-netty-http/pom.xml | 14 +++
.../nettyhttp/sink/CamelSinkNettyhttpITCase.java | 5 +-
.../source/CamelNettyHTTPPropertyFactory.java | 60 +++++++++++
.../source/CamelNettyhttpPropertyFactory.java | 63 -----------
.../source/CamelSourceNettyHTTPITCase.java | 119 +++++++++++++++++++++
.../source/CamelSourceNettyhttpITCase.java | 109 -------------------
15 files changed, 459 insertions(+), 201 deletions(-)
create mode 100644
core/src/main/java/org/apache/camel/kafkaconnector/CamelSourceRecord.java
create mode 100644
tests/itests-netty-http/src/test/java/org/apache/camel/kafkaconnector/nettyhttp/source/CamelNettyHTTPPropertyFactory.java
delete mode 100644
tests/itests-netty-http/src/test/java/org/apache/camel/kafkaconnector/nettyhttp/source/CamelNettyhttpPropertyFactory.java
create mode 100644
tests/itests-netty-http/src/test/java/org/apache/camel/kafkaconnector/nettyhttp/source/CamelSourceNettyHTTPITCase.java
delete mode 100644
tests/itests-netty-http/src/test/java/org/apache/camel/kafkaconnector/nettyhttp/source/CamelSourceNettyhttpITCase.java
