Я использую 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:
Ошибка curl предполагает, что ваш запрос проходит через HTTP-прокси Squid. Вы уверены, что оно отправлено правильно? Вы можете позвонить напрямую?
Есть какие-нибудь логи из Kafka Connect?
