You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@camel.apache.org by ac...@apache.org on 2019/12/11 18:36:30 UTC

[camel-kafka-connector] 01/01: Merge pull request #39 from apache/source-record-key

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 37caf101cd7c20fc8c28b6cb4f1b729b80e9855b
Merge: 2464b1a 1d49281
Author: Andrea Cosentino <an...@gmail.com>
AuthorDate: Wed Dec 11 19:36:19 2019 +0100

    Merge pull request #39 from apache/source-record-key
    
    Allow to configure a source record key from camel message header key

 .../kafkaconnector/CamelSourceConnectorConfig.java |  8 ++-
 .../camel/kafkaconnector/CamelSourceTask.java      | 10 +++-
 .../camel/kafkaconnector/utils/SchemaHelper.java   |  3 ++
 .../camel/kafkaconnector/CamelSourceTaskTest.java  | 62 ++++++++++++++++++++++
 4 files changed, 81 insertions(+), 2 deletions(-)