如何从 Flink 将 Avro 格式的数据写入 Kafka

Question

为了从Kafka读取Avro数据，我们有AvroDeserializationSchema。但是写作呢？

Answer 1

有可用于序列化Rows的AvroRowSerializationSchema。如果你需要序列化一个特定的类型，那么我建议实现你自己的模式，因为 Flink 目前不提供任何其他 Avro SerializationSchemas。