Невозможно прочитать поток изменений из mongodb с помощью соединителя Debezium для mongodb ⇐ JAVA

[Anonymous]

Я получаю следующую ошибку при любом обновлении базы данных mongo

Код: Выделить всё

{
"timestamp" : "13-11-2024 T 11:41:12.255Z",
"level" : "ERROR",
"thread" : "debezium-mongodbconnector-goo-debez-mongodb-connector2-change-event-source-coordinator",
"mdc" : {
"dbz.connectorName" : "{connector name as in ${topic.prefix}}",
"dbz.connectorType" : "MongoDB",
"dbz.taskId" : "0",
"dbz.connectorContext" : "streaming"
},
"logger" : "io.debezium.connector.mongodb.connection.MongoDbConnections",
"message" : "Error while attempting to Reading change stream: 'com.mongodb.client.model.changestream.SplitEvent com.mongodb.client.model.changestream.ChangeStreamDocument.getSplitEvent()'",
"context" : "default",
**"exception" : "**java.lang.NoSuchMethodError: 'com.mongodb.client.model.changestream.SplitEvent com.mongodb.client.model.changestream.ChangeStreamDocument.getSplitEvent()****'\r\n\tat io.debezium.connector.mongodb.events.SplitEventHandler.handle(SplitEventHandler.java:34)\r\n\tat io.debezium.connector.mongodb.MongoDbStreamingChangeEventSource.processChangeStreamDocument(MongoDbStreamingChangeEventSource.java:145)\r\n\tat io.debezium.connector.mongodb.MongoDbStreamingChangeEventSource.lambda$readChangeStream$1(MongoDbStreamingChangeEventSource.java:113)\r\n\tat java.base/java.util.Optional.map(Optional.java:260)\r\n\tat io.debezium.connector.mongodb.MongoDbStreamingChangeEventSource.readChangeStream(MongoDbStreamingChangeEventSource.java:113)\r\n\tat io.debezium.connector.mongodb.MongoDbStreamingChangeEventSource.lambda$execute$0(MongoDbStreamingChangeEventSource.java:85)\r\n\tat io.debezium.connector.mongodb.connection.MongoDbConnection.lambda$execute$0(MongoDbConnection.java:89)\r\n\tat io.debezium.connector.mongodb.connection.MongoDbConnection.execute(MongoDbConnection.java:105)\r\n\tat io.debezium.connector.mongodb.connection.MongoDbConnection.execute(MongoDbConnection.java:88)\r\n\tat io.debezium.connector.mongodb.MongoDbStreamingChangeEventSource.execute(MongoDbStreamingChangeEventSource.java:84)\r\n\tat io.debezium.connector.mongodb.MongoDbStreamingChangeEventSource.execute(MongoDbStreamingChangeEventSource.java:37)\r\n\tat io.debezium.pipeline.ChangeEventSourceCoordinator.streamEvents(ChangeEventSourceCoordinator.java:312)\r\n\tat io.debezium.pipeline.ChangeEventSourceCoordinator.executeChangeEventSources(ChangeEventSourceCoordinator.java:203)\r\n\tat io.debezium.pipeline.ChangeEventSourceCoordinator.lambda$start$0(ChangeEventSourceCoordinator.java:143)\r\n\tat java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:539)\r\n\tat java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264)\r\n\tat java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136)\r\n\tat java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635)\r\n\tat java.base/java.lang.Thread.run(Thread.java:842)\r\n"
}

Я могу получить первоначальный снимок событий в mongoDB, но при внесении некоторых изменений в базу данных он не выдает события в реальном времени и выдает вышеуказанную ошибку. Чего может не хватать?
Я пробовал менять режимы на no_data(раньше никогда) и всегда, но не помогло.

Подробнее здесь: https://stackoverflow.com/questions/791 ... or-mongodb