Skip to content

Instantly share code, notes, and snippets.

@lucndm
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.
Config connect in kafka connection
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
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment