.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
Hi!
I think this is a known limitation for Flink 1.0 and it is fixed in Flink
1.1
Here is the JIRA ticket: https://issues.apache.org/jira/browse/FLINK-3691
Here is the mail thread:
http://mail-archives.apache.org/mod_mbox/flink-user/201604.mbox/%3CCAOFSxKtJXfxRKm2=bplu+xvpwqrwd3c8ynuk3iwk9aqvgrc
