0

我正在使用Mongo-Kafka创建源连接器。（版本：mongo-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"
    }
}

知道如何解决这个问题吗？

4

0 回答 0