deploy-templates/templates/JdbcSinkConnectorCR.yaml (24 lines of code) (raw):
apiVersion: kafka.strimzi.io/v1beta2
kind: KafkaConnector
metadata:
labels:
strimzi.io/cluster: {{ .Values.kafkaConnectConf.clusterName }}
name: {{ .Values.kafkaConnectConf.auditConnectorName }}
spec:
class: 'io.confluent.connect.jdbc.JdbcSinkConnector'
tasksMax: 1
config:
value.converter.schema.registry.url: {{ .Values.kafkaConnectConf.schemaRegistryUrl }}
value.converter: 'io.confluent.connect.avro.AvroConverter'
topics: 'audit-events'
name: {{ .Values.kafkaConnectConf.auditConnectorName }}
connection.password: '${env:DB_PASSWORD}'
connector.class: 'io.confluent.connect.jdbc.JdbcSinkConnector'
table.name.format: 'audit_event'
connection.user: '${env:DB_USER}'
auto.evolve: 'true'
connection.url: {{ .Values.kafkaConnectConf.dbConnectionUrl }}
transforms: 'TimestampConverter'
transforms.TimestampConverter.field: 'timestamp'
transforms.TimestampConverter.type: 'org.apache.kafka.connect.transforms.TimestampConverter$Value'
transforms.TimestampConverter.target.type: 'Timestamp'