Ошибка: конфигурация не определена: тема

Question

Мой Kafka Connect находится в кластере Kubernetes с mongo-kafka-connect-1.1.0-all.jar в папке коннекторов.

У меня есть порт, перенаправленный сервис Kafka Connect на мой локальный хост, и я пытаюсь загрузить свойства для Mongo Sink Connector с помощью этой команды curl (очевидно, с моими собственными данными о подключении в соответствующем <> мест):

curl -X PUT http://localhost:8083/connectors/sink-mongodb/config -H "Content-Type: application/json" -d '{
      "connector.class":"com.mongodb.kafka.connect.MongoSinkConnector",
      "tasks.max":"1",
      "topics":"<topic name>",
      "connection.uri":"mongodb://<username>:<password>@<uri1>:<port1>,<uri2>:<port2>",
      "database":"<database name>",
      "collection":"<collection name>",
      "key.converter":"org.apache.kafka.connect.storage.StringConverter",
      "key.converter.schemas.enable":false,
      "value.converter":"org.apache.kafka.connect.json.JsonConverter",
      "value.converter.schemas.enable":false
}'

Однако я получаю следующий ответ об ошибке:

{"error_code":400,"message":"Connector configuration is invalid and contains the following 1 error(s):\nConfiguration is not defined: topic\nUnable to connect to the server.\nYou can also find the above list of errors at the endpoint `/{connectorType}/config/validate`"}

Моя конфигурация неправильная, я что-то упускаю?

Answer 1

Я попробовал 1.0.1 вместо 1.1.0 - то есть mongo-kafka-connect-1.0.1-all.jar - в качестве плагина, и эта ошибка исчезла.

Answer 2

Итак, в конце концов, проблема заключалась в том, что мне нужно было взять .pemфайл и преобразовать его в .crtи добавьте это в список ЦС сервера. По сути, сервер не принял сертификат SSL и отказывался подключаться.

Answer 3

Я столкнулся с той же проблемой. Изменение образа докера с mongo:4.0.xenial на mongo:4.0.4 решило проблему.