Разъем Kafka Sink для MongDB истекает после короткого периода бездействия

Question

Я пытаюсь использовать коннектор приемника MongoDB для передачи данных из Kafka в Mongo. Я использую официальный коннектор приемника MongoDB для Kafka. Мой экземпляр MongoDB в облаке Azure. Коннектор работает нормально при включении и обработке данных. Но через некоторое время истекло время ожидания с "com.mongodb.MongoSocketReadException: сообщение о получении исключения" вместе с "Причиной: java.net.SocketException: время ожидания соединения истекло (ошибка чтения)".

Конфигурация коннектора:

curl -X PUT http://localhost:8083/connectors/mongo-sink/config -H "Content-Type: application/json" -d ' {
      "connector.class":"com.mongodb.kafka.connect.MongoSinkConnector",
      "tasks.max":"1",
      "topics":"topic-test",
      "connection.uri":"mongodb://user:password@azurehostname:27017/poc-db?authSource=poc-db&readPreference=primary&appname=MongoDB%20Compass&ssl=false",
      "database":"poc-db",
      "collection":"aggregated-price",
      "key.converter":"org.apache.kafka.connect.json.JsonConverter",
      "key.converter.schemas.enable":false,
      "value.converter":"org.apache.kafka.connect.json.JsonConverter",
      "value.converter.schemas.enable":false
}'

В среде Dev не так много трафика. Итак, я подозреваю, что это может быть тайм-аут простоя. Кто-нибудь видел подобную проблему? Могут ли помочь какие-либо настройки на стороне клиента или сервера?

Ценю любую помощь.