Я пытаюсь настроить соединитель sqlserver debezium в kafka на windows, для этого я скачал соединитель с здесь и установил kafka в C:\kafka_2.11-2.4.0 location
создал папку назвал плагины внутри него C:\kafka_2.11-2.4.0\plugins и скопировал загруженный файл jar в папку плагинов.
после этого создал файлы worker.properties и sqlserverconnector.properties в папке конфигурации с конфигурацией ниже
worker .properties config
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
также настроил свойство connect.standalone plugin.path для папки.
при попытке запустить соединитель с помощью следующей команды
C: \ kafka_2.11-2.4.0 \ bin \ windows> connect-standalone ../../ config / worker.properties ../../config/sqlserverconnector.properties
Я получаю следующее сообщение
Failed to find any class that implements Connector and which name matches io.debezium.connector.sqlserver.SqlServerConnector
полная информация об ошибке на этом изображении
, если я пытаюсь запустить Connect-Stan dalone. sh с помощью приведенной ниже команды открывается новое окно командной строки и ничего не происходит, оно через некоторое время закрывается.
C: \ kafka_2.11-2.4.0 \ bin> connect- standalone. sh ../config/worker.properties ../config/sqlserverconnector.properties
может кто-нибудь помочь мне найти причину проблемы и правильно настроить ..