cvalente-il

…
debezium-connect-cluster-connect 2022-05-11 13:26:25,425 INFO [debezium-connector-postgres|task-0] REPLICA IDENTITY for 'inventory.spatial_ref_sys' is 'DEFAULT'; UPDATE and DELETE events will contain previous values only for PK columns (io.debezium.connector.postgresql.PostgresSchema) [debezium-postgresconnector-postgres-change-event-source-coordinator]
debezium-connect-cluster-connect 2022-05-11 13:26:25,436 INFO [debezium-connector-postgres|task-0] REPLICA IDENTITY for 'inventory.geom' is 'DEFAULT'; UPDATE and DELETE events will contain previous values only for PK columns (io.debezium.connector.postgresql.PostgresSchema) [debezium-postgresconnector-postgres-change-event-source-coordinator]
debezium-connect-cluster-connect 2022-05-11 13:26:25,437 INFO [debezium-connector-postgres|task-0] REPLICA IDENTITY for 'inventory.products_on_hand' is 'FULL'; UPDATE AND DELETE events will contain the previous values of all the columns (io.debezium.connector.postgresql.PostgresSchema) [debezium-postgresconnector-postgr

cvalente-il

apiVersion: kafka.strimzi.io/v1beta2
kind: KafkaConnector
metadata:
  name: debezium-connector-bigquery
  labels:
    strimzi.io/cluster: debezium-connect-cluster
spec:
  class: com.wepay.kafka.connect.bigquery.BigQuerySinkConnector
  tasksMax: 1
  config:

cvalente-il

{
    "schema": { ... },
    "payload": {
        "before": { 
            "id": 1
        },
        "after": { 
            "id": 1,
            "first_name": "Anne Marie",
            "last_name": "Kretchmar",

cvalente-il

apiVersion: kafka.strimzi.io/v1beta2
kind: KafkaConnector
metadata:
  name: debezium-connector-postgres
  labels:
    strimzi.io/cluster: debezium-connect-cluster
spec:
  class: io.debezium.connector.postgresql.PostgresConnector
  tasksMax: 1
  config:

cvalente-il

apiVersion: kafka.strimzi.io/v1beta2
kind: KafkaConnect
metadata:
  name: debezium-connect-cluster
  annotations:
    strimzi.io/use-connector-resources: "true"
spec:
  version: 3.1.0
  replicas: 1
  bootstrapServers: debezium-cluster-kafka-bootstrap:9092