install/helm/nrt-pm-kafka-connect/templates/app-kafka-connector.yaml

   1 #  ============LICENSE_START===============================================
   2 #  Copyright (C) 2023 Nordix Foundation. All rights reserved.
   3 #  ========================================================================
   4 #  Licensed under the Apache License, Version 2.0 (the "License");
   5 #  you may not use this file except in compliance with the License.
   6 #  You may obtain a copy of the License at
   7 #
   8 #       http://www.apache.org/licenses/LICENSE-2.0
   9 #
  10 #  Unless required by applicable law or agreed to in writing, software
  11 #  distributed under the License is distributed on an "AS IS" BASIS,
  12 #  WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  13 #  See the License for the specific language governing permissions and
  14 #  limitations under the License.
  15 #  ============LICENSE_END=================================================
  16 #
  17
  18 apiVersion: kafka.strimzi.io/v1beta2
  19 kind: KafkaConnector
  20 metadata:
  21   name: influx2-sink-connector
  22   namespace: nonrtric
  23   labels:
  24     strimzi.io/cluster: pm-connect-cluster
  25 spec:
  26   class: org.custom.camel.kafkaconnector.influxdb2.CamelInfluxdb2SinkConnector
  27   tasksMax: 1
  28   config:
  29     topics: pmreports
  30     errors.deadletterqueue.topic.name: pmreports-dl
  31     errors.deadletterqueue.topic.replication.factor: 1
  32     key.converter: org.apache.kafka.connect.storage.StringConverter
  33     value.converter: org.apache.kafka.connect.json.JsonConverter
  34     key.converter.schemas.enable: false
  35     value.converter.schemas.enable: false
  36     key.ignore: true
  37     auto.create: true
  38     transforms: t1
  39     transforms.t1.type: org.custom.camel.kafkaconnector.influxdb2.transform.points.Influxdb2PmsTransform$Value
  40     transforms.t1.measurement.name: pms_data
  41     camel.beans.influxdb2: "${file:/opt/kafka/external-configuration/influxdb2-connection-bean/influxdb2.properties:influxdb2_connection_bean}"
  42     camel.sink.path.connectionBean: influxdb2
  43     camel.sink.endpoint.bucket: ts_pms_metrics
  44     camel.sink.endpoint.org: est
  45     camel.sink.endpoint.operation: insert
  46     camel.sink.endpoint.autoCreateBucket: true