为了在我本地的ubuntu机器上运行cdc-kafka-connect,我正在通过独立的confluent安装程序运行它。
对于kafka connect microsoft sql server连接器,
配置,kafka-connect-mssql.json
{
"name" : "msSqlSourceConnector2",
"config" : {
"connector.class" : "io.confluent.connect.cdc.mssql.MsSqlSourceConnector",
"tasks.max" : "1",
"initial.database" : "MyDB",
"username" : "SYS",
"password" : "Mysql@123",
"server.name" : "localhost",
"server.port" : "1433",
"topics": "MsSql"
}
}
运行以下命令启动生产者,
./bin/confluent load msSqlSourceConnector2 -d <path>/kafka-connect-mssql.json
低于结果,
CLI is intended for development only, not for production
https://docs.confluent.io/current/cli/index.html
{
"name": "msSqlSourceConnector2",
"config": {
"connector.class": "io.confluent.connect.cdc.mssql.MsSqlSourceConnector",
"tasks.max": "1",
"initial.database": "MyDB",
"username": "SYS",
"password": "Mysql@123",
"server.name": "localhost",
"server.port": "1433",
"topics": "MsSql",
"name": "msSqlSourceConnector2"
},
"tasks": [],
"type": null
}
当我运行consumer时,它没有显示任何结果,
./bin/kafka-console-consumer --bootstrap-server localhost:9092 --from-beginning --property print.key=true --topic MsSql
在ms-sql方面,当我执行insert、update和delete时,它捕获了相应cdc表中的更改。
任何时候如果有人玩这个连接器,请告诉我。
暂无答案!
目前还没有任何答案,快来回答吧!