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

DBZ-234 Support try with resource for engine

Browse Source
This commit is contained in:
Jiri Pechanec 2020-02-28 09:49:18 +01:00 committed by Gunnar Morling
parent be77831e7d
commit f203af29de
2 changed files with 8 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
debezium-api/src/main/java/io/debezium/engine/DebeziumEngine.java
View File

@ -5,6 +5,7 @@
*/
package io.debezium.engine;
import java.io.Closeable;
import java.time.Clock;
import java.util.Iterator;
import java.util.List;
@ -39,7 +40,7 @@
* @author Randall Hauch
*/
@Incubating
public interface DebeziumEngine<R> extends Runnable {
public interface DebeziumEngine<R> extends Runnable, Closeable {
public static final String OFFSET_FLUSH_INTERVAL_MS_PROP = "offset.flush.interval.ms";

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

@ -5,6 +5,7 @@
*/
package io.debezium.embedded;
import java.io.IOException;
import java.time.Duration;
import java.util.List;
import java.util.Map;
@ -948,6 +949,11 @@ public boolean stop() {
return false;
}
@Override
public void close() throws IOException {
stop();
}
/**
* Wait for the connector to complete processing. If the processor is not running, this method returns immediately; however,
* if the processor is {@link #stop() stopped} and restarted before this method is called, this method will return only
@ -988,5 +994,4 @@ protected EmbeddedConfig(Map<String, String> props) {
super(CONFIG, props);
}
}
}