public class CanalDataFormat extends AbstractJsonDataFormat
CanalRecordParser
.Constructor and Description |
---|
CanalDataFormat() |
Modifier and Type | Method and Description |
---|---|
protected RecordParserFactory |
parser()
Factory for creating AbstractRecordParser.
|
kafkaDeserializer, pulsarDeserializer
createKafkaDeserializer, createParser, createPulsarDeserializer
protected RecordParserFactory parser()
AbstractDataFormat
parser
in class AbstractDataFormat
Copyright © 2023–2024 The Apache Software Foundation. All rights reserved.