Debezia MSSQL服务器连接器问题

Question

Kafka新来的。

环境设置

操作系统：Ubuntu 20.04

Kafka安装在主文件夹中的本地机器上。Kafka和Zoo的服务都在运行。

我正在尝试配置Kafka connect以连接到托管在SQL Server容器中的数据库，我使用下面的命令构建了该容器

< code > docker run-name SQL 19-p 1433:1433-e " ACCEPT _ EULA = Y "-e " SA _ PASSWORD = PASSWORD 258 * "-e " MSSQL _ AGENT _ ENABLED = True "-v ~/SQL docker vol/user database:/user database-v ~/SQL docker vol/SQL backups:/SQL backups-d mcr.microsoft.com/mssql/server:2019-latest

容器正在运行，可以成功连接。

我在数据库级和表级启用了CDC。

EXEC sys.sp_cdc_enable_db
GO
EXEC sys.sp_cdc_enable_table
    @source_schema = N'dbo',
    @source_name   = N'WorkQueue',
    @role_name     = NULL,
    @supports_net_changes = 1

连接器属性文件

name= DebeziumSQLServerconnector 
connector.class= io.debezium.connector.sqlserver.SqlServerConnector 
database.hostname=linuxdesktop 
database.port= 1433 
database.user= sa 
database.password= Password258* 
database.dbname= mydb 
database.server.name= linuxdesktop 
table.include.list= dbo.WorkQueue 
database.history.kafka.bootstrap.servers= linuxdesktop:9092 
database.history.kafka.topic= dbhistory.mydb 

独立连接。属性plugin.path

plugin.path=/home/vinu/kafka服务器/连接器

我复制了所有的.JAR 文件到 plugin.path 中

然后我尝试使用以下命令启动连接器

~/kafka-server/bin/connect-standalone.sh ~/kafka-server/config/connect-standalone.properties  DebeziumSQLServerconnector.properties

但进程无法启动并得到以下错误消息

会有什么问题呢？

注：所有Kafka组件都安装在机器的本地。我的设置中唯一的容器是SQL Server。

Answer 1

您不能将连接器jar放入< code >/home/vinu/Kafka-server/connector 中，而是放入< code >/home/vinu/Kafka-server/connector/debezium-SQL server-connector 或任何其他名称中。连接器不放在< code>plugin.path中，而是放在< code>plugin.path中的一个单独的目录中。

Answer 2

可用的连接器列出了该类，因此您的插件很好。

你有空间问题。注意日志输出的逗号位置

match io.debezium.connector.sqlserver.SqlServerConnector ，

从整个属性文件中删除尾随空格和值前的前导空格