alexey.rassokhin/tet123
1
0
Fork 0
Code Issues Pull Requests 1 Packages Projects Releases Wiki Activity

DBZ-4742 change connect config to use WorkerConfig values for interpolation

Browse Source
This commit is contained in:
zalmane 2022-02-13 18:46:09 +02:00 committed by Jiri Pechanec
parent 5b4989a7c0
commit e679b37849
1 changed files with 1 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
debezium-embedded/src/main/java/io/debezium/embedded/EmbeddedEngine.java
View File

@ -724,7 +724,7 @@ public void raiseError(Exception e) {
try {
// Start the connector with the given properties and get the task configurations ...
connector.start(config.asMap());
connector.start(workerConfig.originalsStrings());
connectorCallback.ifPresent(DebeziumEngine.ConnectorCallback::connectorStarted);
List<Map<String, String>> taskConfigs = connector.taskConfigs(1);
Class<? extends Task> taskClass = connector.taskClass();