flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Chesnay Schepler <ches...@apache.org>
Subject Re: Can't get keyed messages from Kafka
Date Tue, 13 Jun 2017 11:41:27 GMT
You have to create your own implementation that deserializes the byte 
arrays into whatever type you want to use.

On 13.06.2017 13:19, AndreaKinn wrote:
> But KeyedDeserializationSchema has just 2 implementations:
>
> TypeInformationKeyValueSerializationSchema
> JSONKeyValueDeserializationSchema
>
>
> The first give me this error:
>
> 06/12/2017 02:09:12 Source: Custom Source(4/4) switched to FAILED
> java.io.EOFException at
> org.apache.flink.runtime.util.DataInputDeserializer.readUnsignedByte(DataInputDeserializer.java:306)
>
> while the JSONObject obviously doesn't fit my needs.
>
> I thinking about to implement a custom deserialiser but honestly I'm a
> newbie and I don't know how to start.
>
>
>
> --
> View this message in context: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/Can-t-get-keyed-messages-from-Kafka-tp13687p13689.html
> Sent from the Apache Flink User Mailing List archive. mailing list archive at Nabble.com.
>


Mime
View raw message