Kafka无法找到连接器插件，即使配置plugin.pathworker.properties

Question

我正在尝试在windows上的kafka中配置sqlserver debezium connector，为此，我从这里下载了连接器，并在C:\kafka_2.11-2.4.0位置设置kafka

在其中创建了一个名为plugins的文件夹，并将下载的jar复制到plugins文件夹中。

之后创建了worker。属性和sqlserverconnector。配置文件夹中的属性文件具有以下配置

worker.properties配置

offset.storage.file.filename=/tmp/connect.offsets 
bootstrap.servers=localhost:9092 
offset.flush.interval.ms=10000
#rest.port=10082
#rest.host.name=localhost
#rest.advertised.port=10082
#rest.advertised.host.name=<hostname> 
internal.key.converter=org.apache.kafka.connect.json.JsonConverter 
internal.value.converter=org.apache.kafka.connect.json.JsonConverter 
internal.key.converter.schemas.enable=false 
internal.value.converter.schemas.enable=false 
key.converter=org.apache.kafka.connect.json.JsonConverter 
value.converter=org.apache.kafka.connect.json.JsonConverter 
plugin.path=c:\kafka_2.11-2.4.0\plugins
#If kafka is TLS authenticated, uncomment below lines.
#security.protocol=SSL 
#ssl.truststore.location=/tmp/kafka.client.truststore.jks
#producer.security.protocol=SSL
#producer.ssl.truststore.location=/tmp/kafka.client.truststore.jks

sqlserverconnector.properties

name=sql-server-connection
connector.class=io.debezium.connector.sqlserver.SqlServerConnector
database.hostname=localhost
database.port=1433
database.user=sa
database.password=Passw0rd
database.dbname=CDCTestDB
#database.server.name=<Assign any name>
#table.whitelist=<schema_name.table_name>
database.history.kafka.bootstrap.servers=localhost:9092
database.history.kafka.topic=test
#If kafka is TLS authenticated, uncomment below lines.
#database.history.producer.security.protocol=SSL
#database.history.producer.ssl.truststore.location=/tmp/kafka.client.truststore.jks

还配置了连接。独立插件。文件夹的路径属性。

当我尝试使用以下命令运行连接器时

C： \kafka_2.11-2.4.0\bin\windows

我收到以下消息

 Failed to find any class that implements Connector and which name matches io.debezium.connector.sqlserver.SqlServerConnector 

在此图像中填写错误详细信息

如果我尝试独立运行connect。sh使用下面的命令，一个新的命令提示窗口即将出现，但什么也没有发生，它会在一段时间后关闭。

C：\kafka_2.11-2.4.0\bin

任何人都可以帮助我找到可能的问题并正确配置...

Answer 1

您不能将Debezium连接器JAR放入插件中。dir，但指向此dir的子目录。所以如果插件。dir是c:\connect，那么您应该有c:\connect\debezium连接器sqlserver