Skip to content

Instantly share code, notes, and snippets.

Show Gist options
  • Save romanbonapart/81da1b04cff553fd7911f2b2709dfb31 to your computer and use it in GitHub Desktop.
Save romanbonapart/81da1b04cff553fd7911f2b2709dfb31 to your computer and use it in GitHub Desktop.
connector.class=io.debezium.connector.mysql.MySqlConnector
tasks.max=1
database.history.kafka.topic=dbhistory.debezium-poc.mysql
database.history.producer.sasl.client.callback.handler.class=software.amazon.msk.auth.iam.IAMClientCallbackHandler
database.history.consumer.sasl.client.callback.handler.class=software.amazon.msk.auth.iam.IAMClientCallbackHandler
database.history.consumer.security.protocol=SASL_SSL
database.history.producer.security.protocol=SASL_SSL
database.history.consumer.sasl.mechanism=AWS_MSK_IAM
database.history.producer.sasl.mechanism=AWS_MSK_IAM
database.history.consumer.sasl.jaas.config=software.amazon.msk.auth.iam.IAMLoginModule required;
database.history.producer.sasl.jaas.config=software.amazon.msk.auth.iam.IAMLoginModule required;
database.user=admin
database.server.id=123456
database.history.kafka.bootstrap.servers=
database.server.name=debezium-poc
database.port=3306
database.hostname=
database.password=
database.whitelist=dataset
database.include.list=dataset
include.schema.changes=true
tombstones.on.delete=false
key.converter.region=us-east-1
value.converter.region=us-east-1
key.converter=org.apache.kafka.connect.storage.StringConverter
key.converter.schemas.enable=false
value.converter=com.amazonaws.services.schemaregistry.kafkaconnect.AWSKafkaAvroConverter
value.converter.schemas.enable=true
internal.key.converter=com.amazonaws.services.schemaregistry.kafkaconnect.AWSKafkaAvroConverter
internal.key.converter.schemas.enable=false
internal.value.converter=com.amazonaws.services.schemaregistry.kafkaconnect.AWSKafkaAvroConverter
internal.value.converter.schemas.enable=false
key.converter.registry.name=debezium-poc
value.converter.registry.name=debezium-poc
key.converter.schemaAutoRegistrationEnabled=true
value.converter.schemaAutoRegistrationEnabled=true
key.converter.avroRecordType=GENERIC_RECORD
value.converter.avroRecordType=GENERIC_RECORD
snapshot.mode=initial
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment