Пн go - Коннектор источника Kafka не может возобновить поток изменений - PullRequest
Новая
       93

Пн go - Коннектор источника Kafka не может возобновить поток изменений

0 голосов
/ 28 мая 2020

Я использую Mon go -Kafka для создания коннектора источника. (Версия: mon go -kafka-1.0.1-all.jar)

Но я получил логи: 

[2020-05-28 06:28:03,425] INFO Watching for collection changes on 'MyDatabaseName.CollectionName' (com.mongodb.kafka.connect.source.MongoSourceTask)
[2020-05-28 06:28:03,427] INFO New change stream cursor created without offset (com.mongodb.kafka.connect.source.MongoSourceTask)
[2020-05-28 06:28:03,539] INFO Failed to resume change stream: The featureCompatibilityVersion must be 3.6 to use the $changeStream stage. See http://dochub.mongodb.org/core/3.6-feature-compatibility. 72 (com.mongodb.kafka.connect.source.MongoSourceTask)

Журнал показывает, что не удалось возобновить поток изменений.

Но моя версия mongodb - 3.6.6

Содержание сообщения показано ниже: 

{
   "name": "mongo-source1",                                                       
   "config": {
         "connector.class":"com.mongodb.kafka.connect.MongoSourceConnector",      
         "tasks.max":"1",                                                        
         "topics":"test-topic2",
         "connection.uri":"MyMongoURI",
         "database":"MyDatabaseName",                      
         "collection":"CollectionName",  
         "change.stream.full.document": "",
         "value.converter.schemas.enable": "false"
    }
}

Есть идеи, как это исправить?

...