Установка Mirror Maker 2 с использованием метода kafka connect rest api put не разрешена

Я пытаюсь выполнить настройку для производителя зеркала 2, используя текущий кластер подключения. На основе этой документации это можно сделать через connect rest api.

https://cwiki.apache.org/confluence/display/KAFKA/KIP-382%3A+MirrorMaker+2.0#KIP-382:MirrorMaker2.0-RunningMirrorMakerinaConnectcluster

Я следил за образцом, отправившим этот запрос PUT:

PUT / коннекторы / us-west-source / config HTTP / 1.1

{
    "name": "us-west-source",
    "connector.class": "org.apache.kafka.connect.mirror.MirrorSourceConnector",
    "source.cluster.alias": "us-west",
    "target.cluster.alias": "us-east",
    "source.cluster.bootstrap.servers": "us-west-host1:9091",
    "topics": ".*"
}

но я получаю метод, запрещающий ответ на ошибку.

{
  "error_code": 405,
  "message": "HTTP 405 Method Not Allowed"
}

Api выглядит нормально, если я выполняю простой GET из /, возвращая версию

{
  "version": "2.1.0-cp1",
  "commit": "bda8715f42a1a3db",
  "kafka_cluster_id": "VBo-j1OAQZSN8tO4lMJ0Gg"
}

apache-kafka apache-kafka-connect apache-kafka-mirrormaker
person jacktrade    schedule 23.04.2020    source источник
comment
Не уверен, что проблема в MirrorMaker. REST API работает одинаково для всех коннекторов, и если вы используете конечную точку :name/config, поле "name" не требуется   -  person OneCricketeer    schedule 23.04.2020

Ответы (1)


arrow_upward
3
arrow_downward

метод PUT не работает, использование POST работает, как показано в документации по API: https://docs.confluent.io/current/connect/references/restapi.html#get--connectors

Удалите имя коннектора из URL-адреса, как предлагается @ cricket_007, и оберните конфигурацию новым элементом следующим образом:

curl --noproxy "*" -XPOST -H 'Content-Type: application/json' -H 'Accept: application/json' http://localhost:8083/connectors -d'{
    "name": "dc-west-source",
    "config": {
    "connector.class": "org.apache.kafka.connect.mirror.MirrorSourceConnector",
    "source.cluster.alias": "dc-west",
    "target.cluster.alias": "dc-east",
    "source.cluster.bootstrap.servers": "dc-west-cp-kafka-0.domain:32721,dc-west-cp-kafka-1.domain:32722,dc-west-cp-kafka-2.dc.domain:32723",
    "topics": ".*" 
    }
}
' | jq .
person jacktrade    schedule 24.04.2020