kafka-connector.yaml

kafka-connector.yaml

apiVersion: kafka.strimzi.io/v1alpha1
kind: KafkaConnector
metadata:
  labels:
    app: ts-producer
    strimzi.io/cluster: kafka-mysql-connect
    timestamp: 20210105-122118
    type: stream
  name: inventory-mysql-1
spec:
  class: io.debezium.connector.mysql.MySqlConnector
  config:
    column.propagate.source.type: .*
    database.history.kafka.bootstrap.servers: k8s-kafka-external-bootstrap.kafka:9094
    database.history.kafka.topic: ${file:/opt/kafka/external-configuration/stream-inventory/inventory.yaml:database.history.kafka.topic}
    database.hostname: ${file:/opt/kafka/external-configuration/stream-inventory/inventory.yaml:database.hostname}
    database.password: ${file:/opt/kafka/external-configuration/stream-inventory/inventory.yaml:database.password}
    database.port: ${file:/opt/kafka/external-configuration/stream-inventory/inventory.yaml:database.port}
    database.server.id: ${file:/opt/kafka/external-configuration/stream-inventory/inventory.yaml:database.server.id}
    database.server.name: ${file:/opt/kafka/external-configuration/stream-inventory/inventory.yaml:database.server.name}
    database.user: ${file:/opt/kafka/external-configuration/stream-inventory/inventory.yaml:database.user}
    database.whitelist: ${file:/opt/kafka/external-configuration/stream-inventory/inventory.yaml:database.whitelist}
    decimal.handling.mode: ${file:/opt/kafka/external-configuration/stream-inventory/inventory.yaml:decimal.handling.mode}
    include.schema.changes: "true"
    table.whitelist: ${file:/opt/kafka/external-configuration/stream-inventory/inventory.yaml:table.whitelist}
  tasksMax: 1