T
- The desired type you want to map the Kafka source record@FunctionalInterface
public interface SourceRecordMapper<T>
extends java.io.Serializable
Modifier and Type | Method and Description |
---|---|
T |
mapSourceRecord(org.apache.kafka.connect.source.SourceRecord sourceRecord) |
T mapSourceRecord(org.apache.kafka.connect.source.SourceRecord sourceRecord) throws java.lang.Exception
java.lang.Exception