-
Task
-
Resolution: Done
-
Major
-
None
-
None
-
False
-
-
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