/cc Robert, he is looking into extending the Kafka Connectors to support
more of Kafka's direct utilities
On Thu, Sep 22, 2016 at 3:17 PM, Swapnil Chougule <the.swapni...@gmail.com>
> It will be good to have RawSchema as one of the deserialization schema in
> streaming framework (like SimpleStringSchema).
> Many use cases needs data in byte array format after reading from source
> like kafka.
> Any inputs for same ?
> On Mon, Sep 12, 2016 at 11:42 AM, Swapnil Chougule <
> the.swapni...@gmail.com> wrote:
>> Thanks Maximilian. I implemented same & it worked for me. I was under
>> impression that RawSchema is available from flink.
>> On Mon, Sep 5, 2016 at 8:48 PM, Maximilian Michels <m...@apache.org>
>>> Just implement DeserializationSchema and return the byte array from
>>> Kafka. Byte array serialization poses no problem to the Flink
>>> 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
>>> > 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 ?