我想在Flink中使用Avro反序列化KafkaSource流。
查看Flink文档时,我发现了以下代码:
KafkaSource<String> source = KafkaSource.<String>builder()
.setBootstrapServers(BOOTSTRAP_SERVER)
.setTopics(TOPIC)
.setGroupId(CONSUMER_GROUP)
.setStartingOffsets(OffsetsInitializer.earliest())
.setDeserializer(new SimpleStringSchema())
.build();
我想知道是否有可能将new SimpleStringSchema
更改为Avro解串器,如果有,如何更改?
1条答案
按热度按时间ljo96ir51#
使用flink-avro中的AvroDeserializationSchema;存在从Avro模式创建模式以读取通用记录或从用于特定记录的类创建模式的静态方法。