kafka connect microsoft sql server连接器未给出任何结果

5vf7fwbs  于 2021-06-07  发布在  Kafka
关注(0)|答案(0)|浏览(307)

为了在我本地的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表中的更改。
任何时候如果有人玩这个连接器,请告诉我。

暂无答案!

目前还没有任何答案,快来回答吧!

相关问题