-
Task
-
Resolution: Done
-
Major
-
None
-
None
-
False
-
None
-
False
-
-
public static ConnectorConfiguration forMongoDbContainer(MongoDBContainer mongoDbContainer) { final List<Integer> exposedPorts = mongoDbContainer.getExposedPorts(); ConnectorConfiguration configuration = new ConnectorConfiguration(); configuration.with(CONNECTOR, "io.debezium.connector.mongodb.MongoDbConnector") .with(HOSTS, "rs0/" + mongoDbContainer.getContainerInfo().getConfig().getHostName() + ":" + exposedPorts.get(0)) .with(AUTO_DISCOVER_MEMBERS, false); return configuration; }
Modify the forMongoDbContainer method to use connection string and use the io.debezium.testing.testcontainers.MongoDbContainer class in the method parameter.
- links to
-
RHEA-2023:120698 Red Hat build of Debezium 2.3.4 release