flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Soheil Pourbafrani <soheil.i...@gmail.com>
Subject Creating flink byte[] deserialiser
Date Mon, 27 Nov 2017 08:18:51 GMT
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

Mime
View raw message