File tree Expand file tree Collapse file tree
debezium-server-http/src/test/java/io/debezium/server/http Expand file tree Collapse file tree Original file line number Diff line number Diff line change 1010
1111import org .apache .kafka .connect .runtime .standalone .StandaloneConfig ;
1212
13- import io .debezium .embedded .ConvertingEngineBuilderFactory ;
13+ import io .debezium .embedded .async . ConvertingAsyncEngineBuilderFactory ;
1414import io .debezium .server .TestConfigSource ;
1515
1616public class HttpTestConfigSource extends TestConfigSource {
@@ -31,7 +31,7 @@ public HttpTestConfigSource() {
3131 httpTest .put ("debezium.transforms.addheader.type" , "org.apache.kafka.connect.transforms.InsertHeader" );
3232 httpTest .put ("debezium.transforms.addheader.header" , "headerKey" );
3333 httpTest .put ("debezium.transforms.addheader.value.literal" , "headerValue" );
34- httpTest .put ("debezium.engine.factory" , ConvertingEngineBuilderFactory .class .getName ());
34+ httpTest .put ("debezium.engine.factory" , ConvertingAsyncEngineBuilderFactory .class .getName ());
3535
3636 config = httpTest ;
3737 }
You can’t perform that action at this time.
0 commit comments