错误：使用 kafka-connect-cdc-mssql:1.0.0-preview答案

【问题标题】：ERROR: using kafka-connect-cdc-mssql:1.0.0-preview错误：使用 kafka-connect-cdc-mssql:1.0.0-preview
【发布时间】：2019-01-01 06:34:40
【问题描述】：

我尝试使用 Kafka 连接器读取日志事务，使用连接器 kafka-connect-cdc-mssql:1.0.0-preview

我正在使用 Confluent CLI，并且我已经修改了配置文件：

etc/schema-registry/connect-avro-standalone.properties

我补充：

plugin.path=/usr/share/java,/tmp/Softwares/confluent-hub-client-latest/share/confluent-hub-components/confluentinc-kafka-connect-cdc-mssql/lib

我有这个问题：当我运行命令时 $合流加载-d

$ confluent load mssqlCDC -d /tmp/Softwares/confluent-hub-client-latest/share/confluent-hub-components/confluentinc-kafka-connect-cdc-mssql/etc/mssqlsource.properties

我收到此错误消息：

(23) Failed writing body

我的存档 mssqlsource.properties：

name=mssqlsource
tasks.max=2
connector.class=io.confluent.connect.cdc.mssql.MsSqlSourceConnector
initial.database=(MYDATABASE)
server.name=(MYSERVER)
server.port=(PORT)
username=(MYUSER)
password=(MYPASS)
change.tracking.tables=(MYTABLE)

【问题讨论】：

标签： sql-server apache-kafka apache-kafka-connect confluent-platform

【解决方案1】：

confluent load 命令实际上是在后台运行 curl 命令，您自己运行它并得到正确的错误可能更容易，将您的属性文件转换为 mssqlsource.json 文件：

{
  "name": "mssqlsource",
  "config": {
    "tasks.max": 2,
    "connector.class": "io.confluent.connect.cdc.mssql.MsSqlSourceConnector",
    "initial.database": "(MYDATABASE)",
    "server.name": "(MYSERVER)",
    "server.port": "(PORT)",
    "username": "(MYUSER)",
    "password": "(MYPASS)",
    "change.tracking.tables": "(MYTABLE)"
  }
}

然后运行curl -XPOST -H "Content-Type: application/json" --data @/path/to/mssqlsource.json connect-host:8083/connectors

这将为您提供更好的错误消息，并且更接近使用 Kafka Connect 的真实示例，因为 confluent 命令行适用于本地开发环境。

【讨论】：