Table of contents

  1. Debezium Source Connector/debezium-connect

Debezium Source Connector/debezium-connect

  1. The helm chart for debezium-connect should be available under charts/debezium.
  2. Validate image repository and tag: 
    image:
  repository: quay.io/debezium/connect
  tag: <release-version-tag> e.g v1.0.1
  3. Configurations for the following should be on hand to update the values.yaml file- NBS_ODSE hostname, username, password and kafka bootstrap server names. Replace all “EXAMPLE_MSK_KAFKA_ENDPOINT” with Kafka endpoints, Replace all “nbs-db.private-EXAMPLE_DOMAIN” with SQL server domain name, Replace all instances of “EXAMPLE_DB_USER” with SQL Server user name, Replace all instances of “EXAMPLE_DB_USER_PASSWORD” with SQL Server password 
    properties:
  bootstrap_server: "EXAMPLE_MSK_KAFKA_ENDPOINT"
    
sqlserverconnector: 
  config: 
    database.hostname: "nbs-db.private-EXAMPLE_DOMAIN",
    database.port: "1433",
    database.user: "EXAMPLE_DB_USER",
    database.password: "EXAMPLE_DB_USER_PASSWORD",
    database.dbname: "nbs_odse",
    database.names: "nbs_odse",
    database.server.name: "odse",
    database.history.kafka.bootstrap.servers: "EXAMPLE_MSK_KAFKA_ENDPOINT",
    schema.history.internal.kafka.bootstrap.servers: "EXAMPLE_MSK_KAFKA_ENDPOINT"   
env:
  - name: BOOTSTRAP_SERVERS
    value: "EXAMPLE_MSK_KAFKA_ENDPOINT"
  4. Install pod 
    helm install -f ./debezium/values.yaml debezium-connect ./debezium/
  5. Verify if pod is running 
    kubectl get pods
  6. Validate service