我想用 Debezium 获取有关 MongoDB 更改的数据，并将数据写入 Kafka。但是当我使用此命令时
bin/connect-standalone.sh config/connect-standalone.properties mongo.properties
出现 ClassCastException。</p>
[2019-01-06 21:17:54,103] INFO Setting max election id to 7fffffff0000000000000001 from replica set primary localhost:27017 (org.mongodb.driver.cluster:71)
[2019-01-06 21:17:54,103] INFO Setting max set version to 1 from replica set primary localhost:27017 (org.mongodb.driver.cluster:71)
[2019-01-06 21:17:54,104] INFO Discovered replica set primary localhost:27017 (org.mongodb.driver.cluster:71)
[2019-01-06 21:17:54,186] INFO Opened connection [connectionId{localValue:4, serverValue:10}] to localhost:27017 (org.mongodb.driver.connection:71)
[2019-01-06 21:17:54,316] INFO Checking shard details from configuration replica set rs0/127.0.0.1:27017 (io.debezium.connector.mongodb.ReplicaSetDiscovery:68)
[2019-01-06 21:17:54,332] ERROR Error while trying to get information about the replica sets (io.debezium.connector.mongodb.ReplicaSetMonitorThread:85)
java.lang.ClassCastException: org.bson.types.ObjectId cannot be cast to java.lang.String
at org.bson.Document.getString(Document.java:215)
at io.debezium.connector.mongodb.ReplicaSetDiscovery.lambda$getReplicaSets$0(ReplicaSetDiscovery.java:69)
at io.debezium.connector.mongodb.MongoUtil.lambda$onCollectionDocuments$1(MongoUtil.java:152)
at io.debezium.connector.mongodb.MongoUtil.lambda$onCollection$0(MongoUtil.java:131)
at io.debezium.connector.mongodb.MongoUtil.onDatabase(MongoUtil.java:115)
at io.debezium.connector.mongodb.MongoUtil.onCollection(MongoUtil.java:129)
at io.debezium.connector.mongodb.MongoUtil.onCollectionDocuments(MongoUtil.java:148)
at io.debezium.connector.mongodb.ReplicaSetDiscovery.getReplicaSets(ReplicaSetDiscovery.java:67)
at io.debezium.connector.mongodb.ReplicaSetMonitorThread.run(ReplicaSetMonitorThread.java:63)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
at java.lang.Thread.run(Thread.java:745)
我的 mongo.properties：
name=inventory-connector
connector.class=io.debezium.connector.mongodb.MongoDbConnector
mongodb.hosts=rs0/127.0.0.1:27017
mongodb.name=fullfillment
collection.whitelist=inventory.test
这是我第一次搭建。请帮我。非常感谢。