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 85784b5 Merge pull request #337 from
orpiske/enable-test-ref-CAMEL-15219
new 3589ae5 #194 Refactored CamelMain to use
new 042242c fix #194 : Support both marshal and unmarshal in source and
sinks.
new 81edd4b Merge pull request #341 from valdar/issue/194
The 596 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 | 5 +++
.../kafkaconnector/CamelSinkConnectorConfig.java | 6 +++
.../apache/camel/kafkaconnector/CamelSinkTask.java | 12 +++++-
.../kafkaconnector/CamelSourceConnectorConfig.java | 13 ++++--
.../camel/kafkaconnector/CamelSourceTask.java | 12 +++++-
.../utils/CamelKafkaConnectDataformat.java | 35 +++++++---------
.../kafkaconnector/utils/CamelMainSupport.java | 46 +++++++++++++++-------
.../camel/kafkaconnector/DataFormatTest.java | 41 ++++++++++++++++---
docs/modules/ROOT/pages/connectors.adoc | 2 +-
9 files changed, 123 insertions(+), 49 deletions(-)
copy
tests/itests-hdfs/src/test/java/org/apache/camel/kafkaconnector/hdfs/services/RemoteHDFSService.java
=>
core/src/main/java/org/apache/camel/kafkaconnector/utils/CamelKafkaConnectDataformat.java
(56%)
