Thanks Maximilian. I implemented same & it worked for me. I was under impression that RawSchema is available from flink.
Regards, Swapnil On Mon, Sep 5, 2016 at 8:48 PM, Maximilian Michels <m...@apache.org> wrote: > Just implement DeserializationSchema and return the byte array from > Kafka. Byte array serialization poses no problem to the Flink > serialization. > > On Mon, Sep 5, 2016 at 3:50 PM, Swapnil Chougule > <the.swapni...@gmail.com> wrote: > > I am using Kafka consumer in flink 1.1.1 with Kafka 0.8.2. I want to read > > byte array as it is in datastream. I tried to use RawSchema as > > desrialization schema but couldn't find same 1.1.1. > > I want to know whether I have to write my custom implementation for > same ? > > Can somebody help me to sort out same ? > > > > Also passing byte[] to next operator is supported as far as > serialization is > > concerned ? >
