【发布时间】:2021-05-21 12:56:11
【问题描述】:
在 Windows 上运行 kafka。尝试使用命令启动 kafka 连接时出现以下错误:
.\bin\windows\connect-standalone.bat .\config\worker.properties .\config\connector.properties
在connect-standalone.properties 文件上使用插件plugin.path=C:\Kafka\kafka_2.12-2.7.0\plugins\debezium-connector-sqlserver\。
知道为什么插件无法被 kafka conenct 识别吗?
错误:
[2021-02-18 08:21:16,384] ERROR Failed to create job for .\config\connector.properties (org.apache.kafka.connect.cli.ConnectStandalone)
[2021-02-18 08:21:16,384] ERROR Stopping after connector error (org.apache.kafka.connect.cli.ConnectStandalone)
java.util.concurrent.ExecutionException: org.apache.kafka.connect.errors.ConnectException: Failed to find any class that implements Connector and which name matches io.debezium.connector.sqlserver.SqlServerConnector, available connectors are: PluginDesc{klass=class org.apache.kafka.connect.file.FileStreamSinkConnector, name='org.apache.kafka.connect.file.FileStreamSinkConnector', version='2.7.0', encodedVersion=2.7.0, type=sink, typeName='sink', location='classpath'}, PluginDesc{klass=class org.apache.kafka.connect.file.FileStreamSourceConnector, name='org.apache.kafka.connect.file.FileStreamSourceConnector', version='2.7.0', encodedVersion=2.7.0, type=source, typeName='source', location='classpath'}, PluginDesc{klass=class org.apache.kafka.c
【问题讨论】:
-
尝试设置
plugin.path如下:plugin.path=C:\Kafka\kafka_2.12-2.7.0\plugins\ -
可能不应该直接在 Windows 上运行 confluent.io/blog/set-up-and-run-kafka-on-windows-linux-wsl-2
标签: sql-server apache-kafka apache-kafka-connect debezium