Apache Flink可以用Java中的Avro反序列化KafkaSource流吗?

qxsslcnc  于 2022-12-09  发布在  Apache
关注(0)|答案(1)|浏览(125)

我想在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解串器,如果有,如何更改?

ljo96ir5

ljo96ir51#

使用flink-avro中的AvroDeserializationSchema;存在从Avro模式创建模式以读取通用记录或从用于特定记录的类创建模式的静态方法。

相关问题