EmbeddedEngineExecutorService |
CdcSupplierConfiguration.embeddedEngineExecutorService(EmbeddedEngine.Builder embeddedEngineBuilder,
Function<org.apache.kafka.connect.source.SourceRecord,byte[]> valueSerializer,
Function<org.apache.kafka.connect.source.SourceRecord,byte[]> keySerializer,
Function<org.apache.kafka.connect.source.SourceRecord,org.apache.kafka.connect.source.SourceRecord> recordFlattening,
com.fasterxml.jackson.databind.ObjectMapper mapper,
CdcSupplierProperties cdcStreamingEngineProperties) |