Depending on how the key value pair is encoded, you could use the TypeInformationKeyValueSerializationSchema where you provide the BasicTypeInfo.STRING_TYPE_INFO and PrimitiveArrayTypeInfo.BYTE_PRIMITIVE_ARRAY_TYPE_INFO as the key and value type information. But this only works if your data was serialized in a similar fashion.
Cheers, Till On Fri, Apr 22, 2016 at 12:02 AM, prateek arora <prateek.arora...@gmail.com> wrote: > Hi > > I am new for Apache Flink and start using Flink version 1.0.1 > > In my scenario, kafka message have key value pair [String,Array[Byte]] . > > I tried to use FlinkKafkaConsumer08 to fetch data but i dont know how to > write DeserializationSchema for that. > > val stream : DataStream[(String,Array[Byte])] = env.addSource(new > FlinkKafkaConsumer08[(String,Array[Byte])]("a-0",<DeserializationSchema> , > properties)) > > please help me to solve this problem . > > Regards > Prateek >