kafka配置sqlserver连接器,会监听到表中所有数据,以op:r
的类型存入kafka(现有一个表有20w数据),可以配置从启用连接器的那一刻开时监听吗?
{
"name": "sqlserver-cdc-source",
"config": {
"connector.class": "io.debezium.connector.sqlserver.SqlServerConnector",
"database.hostname": "xxx.com",
"database.server.name": "xxx",
"database.port": "1433",
"database.user": "user",
"database.password": "password",
"database.dbname": "dbname",
"table.whitelist": "dbo.table",
"schemas.enable": "false",
"mode": "incrementing",
"incrementing.column.name": "id",
"database.history.kafka.bootstrap.servers": "172.28.153.222:9092",
"database.history.kafka.topic": "YwHddzCdc",
"value.converter.schemas.enable": "false",
"value.converter": "org.apache.kafka.connect.json.JsonConverter"
}
}
在
connect-distributed.properties
中, 你可以通过:来设置你的读取方式。
好的,谢谢。我试一下
你的答案