Debezium не находит плагин пользовательского преобразования ⇐ JAVA

[Anonymous]

У меня есть собственный плагин преобразования Debezium, который называется debezium-smts jar. Файл содержит класс, полный путь которого — com.rm.debezium.transforms.MyTransform. Я использую дебезиум в докере, и поэтому, во-первых, моя конфигурация компоновки докера для дебезиума:

Код: Выделить всё

debezium:
container_name: debezium
image: quay.io/debezium/connect:3.2.0.Final
ports:
- 8083:8083
networks:
- reporting_network
environment:
BOOTSTRAP_SERVERS: kafka:29092
PLUGIN_PATH: /connect
volumes:
- ./scripts/local-dev/debezium/plugins:/connect
depends_on:
kafka-init:
condition: service_completed_successfully

Имеет значение параметр PLUGIN_PATH, который указывает на папку scripts/local-dev/debezium/plugins, которая содержит папку debezium-smts и внутри нее мой jar-файл debezium-smts (так что \plugins\debezium-smts\debezium-smts.jar).
Кроме того, файл конфигурации для debezium - это следующее:

Код: Выделить всё

    "transforms"                           = "test"
"transforms.test.type"                 = "com.rm.debezium.transforms.MyTransform"

Однако при запуске моего образа инициализации debezium (инициализация debezium выполняется в контейнере инициализации) я вижу следующую ошибку:

Line |
17 | Invoke-WebRequest -Uri "http://debezium:8083/connectors" `
� | ~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~
� | { "error_code": 400, "message": "Конфигурация соединителя недействительна
� | и содержит следующие 1 ошибки:\nНеверное значение
� | com.rm.debezium.transforms.MyTransform для конфигурации
� | приведенный выше список ошибок в
� конечной точке \u0060/connector-plugins/{connectorType}/config/validate\u0060"
� |

Есть идеи, где я ошибаюсь в своей конфигурации? Я подозреваю, что это как-то связано с неверным именем папки (debezium-smts) под плагином?

Подробнее здесь: https://stackoverflow.com/questions/798 ... orm-plugin