我们正在使用一个集成平台来部署Kafka。我们使用模式注册表来存储模式。是否可以将模式注册中心与flink集成?如何从汇流平台读取AVRO格式的数据?
发布于 2022-06-17 08:21:22
这些类就是为了满足这一需求而设计的。
ConfluentRegistryAvroSerializationSchema
ConfluentRegistryAvroDeserializationSchema
有关类的更多信息,请参见链接的JavaDoc。
每个参数都可以通过各自的序列化方法参数提供给卡夫卡连接器。
Flink SQL也可以使用。
https://stackoverflow.com/questions/72656077
相似问题