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 ?
