This is an automated email from the ASF dual-hosted git repository.
acosentino pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git
commit fb31a84c3509ede8138c0a0ffc4f228262adb92f
Merge: 698b0dc 7047fcc
Author: Andrea Cosentino <anco...@gmail.com>
AuthorDate: Mon Jun 22 19:31:47 2020 +0200
Merge pull request #289 from apache/aggregate-attempt
Aggregate Support
.../kafkaconnector/CamelSinkConnectorConfig.java | 12 +++++-
.../apache/camel/kafkaconnector/CamelSinkTask.java | 3 +-
.../camel/kafkaconnector/CamelSourceTask.java | 2 +-
.../aggregator/StringAggregator.java | 44 ++++++++++++++++++++++
.../kafkaconnector/utils/CamelMainSupport.java | 15 ++++++--
.../camel/kafkaconnector/CamelSinkTaskTest.java | 35 +++++++++++++++++
.../camel/kafkaconnector/DataFormatTest.java | 9 +++--
.../kafkaconnector/utils/SampleAggregator.java | 44 ++++++++++++++++++++++
8 files changed, 153 insertions(+), 11 deletions(-)
