У меня есть 2 существующих сервера kafka, загруженных соединителем mysql. Оно работает. Также мне нужно добавить коннектор MongoDB. Я установил confluent-schema-registry на свои серверы Kafka (Centos7), он работает, я останавливаюсь / запускаю / перезапускаю, все выглядит неправильно. Я скачал и распаковал плагины debezium Mongo здесь; / usr / коннектор / плагины / debezium-connector-mongodb /
Я отредактировал /etc/schema-registry/connect-avro-distributed.properties и изменил следующие строки, как показано ниже:
plugin.path=share/java,/usr/connector/plugins
bootstrap.servers=kafka3:9092,kafka4:9092
rest.host.name=kafka3
rest.port=8084
rest.advertised.host.name=kafka3
rest.advertised.port=8084
Запускаю schema-registry и все в порядке, плагины загружаются. Я хочу загрузить коннектор через REST, как показано ниже:
curl -i -X POST -H "Accept:application/json" \
-H "Content-Type:application/json" http://kafka3:8084/connectors/ \
-d '{
"name": "mongodb-connector",
"config": {
"connector.class": "io.debezium.connector.mongodb.MongoDbConnector",
"mongodb.hosts": "shardreplica01/mongodb-shardsvr1:27017,shardreplica01/mongodb-shardsvr2:27017",
"mongodb.name": "mongoreplica",
"mongodb.user": "debezium",
"mongodb.password": "******",
"database.whitelist": "mongo[.]*",
}
}'
... но отображается следующая ошибка и не удается загрузить коннектор:
HTTP/1.1 500 Internal Server Error
Date: Tue, 21 Jan 2020 20:04:13 GMT
Content-Type: application/json
Content-Length: 350
Server: Jetty(9.4.20.v20190813)
{"error_code":500,"message":"Unexpected character ('}' (code 125)): was expecting double-quote to start field name\n at [Source: (org.glassfish.jersey.message.internal.ReaderInterceptorExecutor$UnCloseableInputStream); line: 9, column: 27] (through reference chain: org.apache.kafka.connect.runtime.rest.entities.CreateConnectorRequest[\"config\"])"}
Мне нужно помочь; что мне не хватает?
Спасибо
