Creating flink byte[] deserialiser

Posted by Soheil Pourbafrani on
URL: http://deprecated-apache-flink-user-mailing-list-archive.369.s1.nabble.com/Creating-flink-byte-deserialiser-tp16900.html

Hi,

I want to read(consume) data from Kafka as byte array just something like Kafka byte array deserializer. In Flink I just find SimpleStringSchema and it is note suitable for my data.

Is any built-in byte array deserializer in Flink or if not how can I create a simple byte array deserializer?

Thanks