-
Bug
-
Resolution: Done
-
Critical
-
None
-
False
-
None
-
False
-
-
Using DBZ version 1.8.0.Final and when we have two fields with the same name ("description" in this case) but belonging to different collections, the connector fails with the following stacktrace:
Caused by: java.lang.IllegalStateException: Duplicate key description (attempted merging values description and description) at java.base/java.util.stream.Collectors.duplicateKeyException(Collectors.java:133) at java.base/java.util.stream.Collectors.lambda$uniqKeysMapAccumulator$1(Collectors.java:180) at java.base/java.util.stream.ReduceOps$3ReducingSink.accept(ReduceOps.java:169) at java.base/java.util.ArrayList$ArrayListSpliterator.forEachRemaining(ArrayList.java:1655) at java.base/java.util.stream.AbstractPipeline.copyInto(AbstractPipeline.java:484) at java.base/java.util.stream.AbstractPipeline.wrapAndCopyInto(AbstractPipeline.java:474) at java.base/java.util.stream.ReduceOps$ReduceOp.evaluateSequential(ReduceOps.java:913) at java.base/java.util.stream.AbstractPipeline.evaluate(AbstractPipeline.java:234) at java.base/java.util.stream.ReferencePipeline.collect(ReferencePipeline.java:578) at io.debezium.connector.mongodb.FieldSelector.fieldFilterFor(FieldSelector.java:198) at io.debezium.connector.mongodb.Filters.fieldFilterFor(Filters.java:96) at io.debezium.connector.mongodb.MongoDbSchema.lambda$schemaFor$0(MongoDbSchema.java:75) at java.base/java.util.concurrent.ConcurrentHashMap.computeIfAbsent(ConcurrentHashMap.java:1705) at io.debezium.connector.mongodb.MongoDbSchema.schemaFor(MongoDbSchema.java:74) at io.debezium.connector.mongodb.MongoDbSchema.schemaFor(MongoDbSchema.java:30) at io.debezium.pipeline.EventDispatcher.dispatchDataChangeEvent(EventDispatcher.java:204) ... 14 more