kafka-connect.yaml

kafka-connect.yaml

apiVersion: kafka.strimzi.io/v1beta1
kind: KafkaConnect
metadata:
  annotations:
    strimzi.io/use-connector-resources: "true"
  labels:
    app: ts-producer
    name:  kafka-mysql-connect
spec:
  tls:
    trustedCertificates:
      - secretName: k8s-cluster-ca-cert
        certificate: ca.crt
  authentication:
    type: tls
    certificateAndKey:
      secretName: kafka-connect
      certificate: user.crt
      key: user.key
  bootstrapServers:  k8s-kafka-external-bootstrap.kafka:9094
  config:
    config.providers: file
    config.providers.file.class: org.apache.kafka.common.config.provider.FileConfigProvider
    config.storage.replication.factor: 1
    config.storage.topic: ts-producer-latest-kafka-mysql-connect-configs
    group.id: ts-producer-latest-kafka-mysql-connect
    internal.key.converter: org.apache.kafka.connect.json.JsonConverter
    internal.value.converter: org.apache.kafka.connect.json.JsonConverter
    key.converter: io.confluent.connect.avro.AvroConverter
    key.converter.schema.registry.url: https://registry.example.com
    offset.storage.replication.factor: 1
    offset.storage.topic: ts-producer-latest-kafka-mysql-connect-offsets
    status.storage.replication.factor: 1
    status.storage.topic: ts-producer-latest-kafka-mysql-connect-status
    value.converter: io.confluent.connect.avro.AvroConverter
    value.converter.schema.registry.url: https://registry.example.com
  externalConfiguration:
    volumes:
    - configMap:
        name: stream-inventory
      name: stream-inventory
  image: connect-debezium:0.19.0-kakfa-2.5.0-mysqlconnector-1.3.0-avro-5.5.0
  replicas: 1