Сконфигурировать коннектор debezium mysql с ошибкой подключения kafka - PullRequest
Новая
       50

Сконфигурировать коннектор debezium mysql с ошибкой подключения kafka

0 голосов
/ 12 сентября 2018

Я использую kafka 2.0 с kafka connect, работающим в распределенном режиме, и попытался настроить разъем debezium mysql, но получаю ошибка 

HTTP/1.1 500 Internal Server Error
Server: squid
Mime-Version: 1.0
Date: Wed, 12 Sep 2018 06:14:40 GMT
Content-Type: text/html;charset=utf-8
Content-Length: 2869
X-Squid-Error: ERR_CANNOT_FORWARD 0
X-Cache: MISS from lnoi3proxy02.one.steria.dom
X-Cache-Lookup: MISS from lnoi3proxy02.one.steria.dom:8080
Connection: keep-alive

Вот звонок: 

curl -i -X POST -H "Accept:application/json" \  
    -H  "Content-Type:application/json" http://localhost:8083/connectors/ \
    -d '{ name": "inventory-connector",
    "config": {
        "connector.class":"io.debezium.connector.mysql.MySqlConnector",
        "database.hostname":"localhost",
        "database.port":"3306",
        "database.user":"root",
        "database.password":"Password@123",
        "database.dbname":"inventory",
         "database.server.id":"41228",
        "database.server.name":"customer",
        "database.whitelist":"inventory",
        "database.history.kafka.bootstrap.servers":"localhost:9092",
        "database.history.kafka.topic":"schema-changes.inventory",
       "include.schema.changes":"true"
      }
}'

kafka-connect logs:

INFO [Worker clientId = connect-1, groupId = connect-clust er] Успешно присоединенная группа с поколением 7 (org.apache.kafka.clients.consum er.internals.AbstractCoordinator: 409) [2018-09-12 07: 38: 17,370] INFO Вступила в группу и получила назначение: Назначение {ошибка = 0, лидер = 'connect-1-63af40e1-da48-4055-99f8-8799582ba5aa', leaderUrl = 'http://l ocalhost: 8083 / ', смещение = -1, connectorIds = [], taskIds = []} (org.apache.kafka.conne ct.runtime.distributed.DistributedHerder: 1194) [2018-09-12 07: 38: 17,373] ИНФОРМАЦИЯ Запуск соединителей и задач с использованием конфигурации смещение -1 (org.apache.kafka.connect.runtime.distributed.DistributedHerder: 842) [2018-09-12 07: 38: 17,373] ИНФОРМАЦИЯ Закончены стартовые соединители и задачи (org.apach e.kafka.connect.runtime.distributed.DistributedHerder: 852) 12 сентября 2018 7:38:17 org.glassfish.jersey.internal.Errors logErrors ПРЕДУПРЕЖДЕНИЕ. Обнаружены следующие предупреждения: ПРЕДУПРЕЖДЕНИЕ. Метод (sub) ресурса createConnector в org.apache.kafka.connect.runtime.rest.resources.Connect orsResource содержит пустую аннотацию пути. ВНИМАНИЕ: (sub) метод ресурса listConnectors в org.apache.kafka.connect.run time.rest.resources.ConnectorsResource содержит пустую аннотацию пути. ПРЕДУПРЕЖДЕНИЕ. Метод (sub) ресурса listConnectorPlugins в org.apache.kafka.conne ct.runtime.rest.resources.ConnectorPluginsResource содержит аннотацию пустого пути. ПРЕДУПРЕЖДЕНИЕ. Метод (sub) ресурса serverInfo в org.apache.kafka.connect.runtime .rest.resources.RootResource содержит пустую аннотацию пути.

[2018-09-12 07: 38: 18,213] ИНФОРМАЦИЯ запущена [2018-09-12 07: 38: 18,223] INFO запущена http_8083 @ 6ec65b5e {HTTP / 1.1} {0.0.0.0:8083} (org.eclipse.jetty.server.ServerConnector: 266) [2018-09-12 07: 38: 18,223] INFO запущена при 15360 мс (org.eclipse.jetty.server.Server: 379) [2018-09-12 07: 38: 18,223] ИНФО объявленный URI: http://localhost:8083/ (org.apach e.kafka.connect.runtime.rest.RestServer: 248) [2018-09-12 07: 38: 18,223] Сервер INFO REST прослушивает http://127.0.0.1:8083/, рекламный URL http://localhost:8083/ (org.apache.kafka.connect.runtime.rest.Re stServer: 207) [2018-09-12 07: 38: 18,223] ИНФОРМАЦИЯ Kafka Connect запущен (org.apache.kafka.connect.r untime.Connect: 55) [2018-09-12 07: 43: 16,612] ID кластерной информации: 8oMHsNLASgubK4CBagB-dw (org.apache.ka fka.clients.Metadata: 265) [2018-09-12 07: 43: 17,052] ID кластерной информации: 8oMHsNLASgubK4CBagB-dw (org.apache.ka fka.clients.Metadata: 265) [2018-09-12 07: 43: 17,289] INFO ID кластера: 8oMHsNLASgubK4CBagB-dw (org.apache.ka fka.clients.Metadata: 265)

1 Ответ

0 голосов
/ 13 сентября 2018

Ошибка от curl предполагает, что ваш запрос идет через http-прокси Squid.Вы уверены, что он правильно перенаправлен?Вы можете сделать прямой звонок?

...