Skip to content

Instantly share code, notes, and snippets.

@lucndm

lucndm/Config connect in kafka connection

Created December 21, 2019 06:26
Show Gist options
  • Save lucndm/ebea868eb9edeeb7f1b71364d0de16a2 to your computer and use it in GitHub Desktop.
Save lucndm/ebea868eb9edeeb7f1b71364d0de16a2 to your computer and use it in GitHub Desktop.
Download ZIP

Revisions

  1. lucndm renamed this gist Dec 21, 2019. 1 changed file with 0 additions and 0 deletions.
    0 gistfile1.txt → Config connect in kafka connection
    View file
    File renamed without changes.
  2. lucndm created this gist Dec 21, 2019.
    24 changes: 24 additions & 0 deletions gistfile1.txt
    View file
    Original file line number Diff line number Diff line change
    @@ -0,0 +1,24 @@
    connector.class=io.debezium.connector.mysql.MySqlConnector
    snapshot.locking.mode=none
    transforms.unwrap.delete.handling.mode=rewrite
    tasks.max=2
    database.history.kafka.topic=dbhistory.be_autos
    buffer.memory=100
    decimal.handling.mode=double
    confluent.topic.replication.factor=3
    poll.interval.ms=200
    value.converter=io.confluent.connect.avro.AvroConverter
    database.whitelist=be_autos
    key.converter=io.confluent.connect.avro.AvroConverter
    database.user=cdc
    database.server.id=574423
    database.history.kafka.bootstrap.servers=cdc-kafka-headless:9092
    database.server.name=be
    offset.flush.timeout.ms=50000
    heartbeat.interval.ms=1000
    database.port=3306
    value.converter.schema.registry.url=http://cdc-schema-registry:8081
    database.hostname=<XXXX>
    database.password=<XXXX>
    key.converter.schema.registry.url=http://cdc-schema-registry:8081
    snapshot.mode=schema_only