.org]
Sent: Thursday, August 04, 2016 6:00 PM
To: user@flink.apache.org
Subject: Re: What is the recommended way to read AVRO data from Kafka using
flink.
Hi!
To read data from Kafka, you need a DeserializationSchema. You could create one
that wraps the AvroInputFormat, but an AvroDeserializationSc
hema* is a must to read data from Kafka, also
> *AvroInputFormat* doesn’t have any javaDoc with it.
>
>
>
>
>
>
>
> Thanks & Regards,
>
> Zeeshan Alam
>
>
>
>
>
>
>
> *From:* Stephan Ewen [mailto:se...@apache.org]
> *Sent:* Tuesday, August 02, 2016 7
data from Kafka, also AvroInputFormat
doesn’t have any javaDoc with it.
Thanks & Regards,
Zeeshan Alam
From: Stephan Ewen [mailto:se...@apache.org]
Sent: Tuesday, August 02, 2016 7:52 PM
To: user@flink.apache.org
Subject: Re: What is the recommended way to read AVRO data from Kafka u
flink/flink-docs-release-0.8/example_connectors.html
> you have mentioned that using the GenericData.Record type is possible with
> Flink, but not recommended. Since the record contains the full schema, its
> very data intensive and thus probably slow to use. So what is the
> recommen
GenericData.Record type is possible with
Flink, but not recommended. Since the record contains the full schema, its very
data intensive and thus probably slow to use. So what is the recommended way to
read AVRO data from Kafka using flink.
public static void main(String[] args) throws Exception
