Как записать данные в формате Avro в Kafka из Flink? - PullRequest
0 голосов
/ 28 марта 2019

Для чтения Avro данных из Kafka у нас есть AvroDeserializationSchema. Но как насчет письма?

1 Ответ

0 голосов
/ 29 марта 2019

Существует AvroRowSerializationSchema, который можно использовать для сериализации Rows. Если вам нужно сериализовать определенный тип, я бы предложил реализовать вашу собственную схему, поскольку Flink на данный момент не предлагает никаких других Avro SerializationSchemas.

...