debezium-postgres-connector.yml

# To use the KafkaConnector resource, you have to first enable the connector operator using
# the strimzi.io/use-connector-resources annotation on the KafkaConnect custom resource.
# From Apache Kafka 3.1.1 and 3.2.0, you also have to add the FileStreamSourceConnector
# connector to the container image. You can do that using the kafka-connect-build.yaml example.
apiVersion: kafka.strimzi.io/v1beta2
kind: KafkaConnector
metadata:
  name: my-deb-postgres-connector
  labels:
    # The strimzi.io/cluster label identifies the KafkaConnect instance
    # in which to create this connector. That KafkaConnect instance
    # must have the strimzi.io/use-connector-resources annotation
    # set to true.
    strimzi.io/cluster: my-connect-cluster
spec:
  class: io.debezium.connector.postgresql.PostgresConnector
  tasksMax: 2
    logging:
      type: inline
      loggers:
        log4j.logger.io.debezium.connector.mysql=DEBUG, stdout
  config:
    database.hostname: 192.168.99.100,
    database.port: 5432,
    database.user: postgres,
    database.password: postgres,
    database.dbname: postgres,
    topic.prefix: fulfillment,
    table.include.list: public.inventory
    publication.autocreate.mode: filtered
    plugin.name: pgoutput