You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
39 lines
1.4 KiB
39 lines
1.4 KiB
#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";
|
|
|
|
|
|
|
|
|
|
|
|
|