public class StringDebeziumDeserializationSchema extends Object implements DebeziumDeserializationSchema<String>
DebeziumDeserializationSchema which converts the received
SourceRecord into String.| Constructor and Description |
|---|
StringDebeziumDeserializationSchema() |
| Modifier and Type | Method and Description |
|---|---|
void |
deserialize(org.apache.kafka.connect.source.SourceRecord record,
org.apache.flink.util.Collector<String> out)
Deserialize the Debezium record, it is represented in Kafka
SourceRecord. |
org.apache.flink.api.common.typeinfo.TypeInformation<String> |
getProducedType() |
public void deserialize(org.apache.kafka.connect.source.SourceRecord record,
org.apache.flink.util.Collector<String> out)
throws Exception
DebeziumDeserializationSchemaSourceRecord.deserialize in interface DebeziumDeserializationSchema<String>ExceptionCopyright © 2022 The Apache Software Foundation. All rights reserved.