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

DBZ-7024 Add missing condition

Browse Source
This commit is contained in:
Vojtech Juranek 2024-02-07 11:53:32 +01:00 committed by Jiri Pechanec
parent 0f7d3100b4
commit 8bb1a122b1
1 changed files with 2 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
debezium-embedded/src/main/java/io/debezium/embedded/AsyncEmbeddedEngine.java
View File

@ -702,7 +702,8 @@ public static final class AsyncEngineBuilder implements DebeziumEngine.Builder<S
@Override @Override
public Builder<SourceRecord> notifying(final Consumer<SourceRecord> consumer) { public Builder<SourceRecord> notifying(final Consumer<SourceRecord> consumer) {
this.consumer = consumer; this.consumer = consumer;
if (config.contains(AsyncEngineConfig.RECORD_PROCESSING_WITH_SERIAL_CONSUMER.name())) { if (config.contains(AsyncEngineConfig.RECORD_PROCESSING_WITH_SERIAL_CONSUMER.name())
&& config.getProperty(AsyncEngineConfig.RECORD_PROCESSING_WITH_SERIAL_CONSUMER.name()).equalsIgnoreCase("true")) {
this.handler = buildDefaultChangeConsumer(consumer); this.handler = buildDefaultChangeConsumer(consumer);
} }
return this; return this;