public static class SourceRecordJson.SourceRecordJsonMapper extends java.lang.Object implements SourceRecordMapper<java.lang.String>
SourceRecordJson
implementation.Constructor and Description |
---|
SourceRecordJsonMapper() |
Modifier and Type | Method and Description |
---|---|
java.lang.String |
mapSourceRecord(org.apache.kafka.connect.source.SourceRecord sourceRecord) |
public java.lang.String mapSourceRecord(org.apache.kafka.connect.source.SourceRecord sourceRecord) throws java.lang.Exception
mapSourceRecord
in interface SourceRecordMapper<java.lang.String>
java.lang.Exception