Hi Soheil,
AFAIK, there is no built-in byte array deserializer in Flink.
However, it is very simple to implement one.
You can do that by implementing the `DeserializationSchema` interface, and for
the implementation of the `deserialize` method, simply return the fetched bytes
from Kafka as the
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?
