#version: kafka-connector, 1.0.0


---
apiVersion: kafka.strimzi.io/v1beta2
kind: KafkaConnector
metadata:
  name: "demo01-kafka-conn-src1-kafka-postgresql"
  namespace: kafka-cluster
  labels:
    strimzi.io/cluster: kafka-cluster
spec:
  class: io.debezium.connector.postgresql.PostgresConnector
  tasksMax: 1
  config:
    database.hostname: "demo01-postgresql2-postgresql-ha-postgresql.demo01-postgresql2.svc.cluster.local"
    database.port: "5432"
    database.user: "postgres"
    database.password: "Gb58gQx8Nhw8"
    database.dbname: "postgres"
    table.include.list: "public.subway_info_copy, public.subway_passengers_copy, public.subway_passengers_time_copy"
    plugin.name: pgoutput
    slot.name: "demo01_kafka_conn_src1_debezium_slot"
    publication.autocreate.mode: filtered
    topic.prefix: "demo01"
    producer.override.security.protocol: "SASL_PLAINTEXT"
    producer.override.sasl.mechanism: "OAUTHBEARER"
    producer.override.sasl.jaas.config: |
      org.apache.kafka.common.security.oauthbearer.OAuthBearerLoginModule required
        oauth.token.endpoint.uri="https://keycloak.gke.paasup.io/realms/paasup/protocol/openid-connect/token"
        oauth.client.id="service-demo01-kafka-common"
        oauth.client.secret="e1eab0a7-ac78-460f-9477-73a910d8871b"
        oauth.ssl.truststore.location="/mnt/truststore/truststore.jks" 
        oauth.ssl.truststore.password="kafka";