Конвертер исходящих событий Debezium Connector - PullRequest
0 голосов
/ 07 апреля 2020

Я пытаюсь использовать MySql Source Connector с SMT Outbox, поддерживаемого debezium, со следующей конфигурацией. Я использую последние банки с дебезиевым ядром и дебезиевым разъемом (mysql) (1.1)

curl -i -X POST -H "Accept:application/json" -H "Content-Type:application/json" localhost: 8083/connectors/ -d '{
    "name": "debezium-mysql-connector",
    "config": {
        "connector.class": "io.debezium.connector.mysql.MySqlConnector",
        "tasks.max": "1",
        "database.hostname": "MySql",
        "database.port": "3306",
        "database.user": "**",
        "database.password": "**",
        "database.server.id": "1033113244",
        "database.server.name": "anomaly-changelog",
        "database.whitelist": "anomaly",
        "database.history.kafka.bootstrap.servers": "Kafka:9092",
        "database.history.kafka.topic": "anomaly.schema.history",
        "transforms": "outbox,reroute",
        "transforms.reroute.type": "org.apache.kafka.connect.transforms.RegexRouter",
        "transforms.reroute.regex": "(.*)",
        "transforms.reroute.replacement": "$1-SMT",
        "transforms.outbox.type": "io.debezium.transforms.outbox.EventRouter"
    }
}'

Но я все еще получаю следующую ошибку:

{"error_code":400,"message":"Connector configuration is invalid and contains the following 2 error(s):\nInvalid value io.debezium.transforms.outbox.EventRouter for configuration transforms.outbox.type: Class io.debezium.transforms.outbox.EventRouter could not be found.\nInvalid value null for configuration transforms.outbox.type: Not a Transformation}

Дон не понимаю, почему его не узнают.

Добро пожаловать на сайт PullRequest, где вы можете задавать вопросы и получать ответы от других членов сообщества.
...