Thank you very much Chao. That helps me.
Regards,
Raja.
From: Chao Wang
Date: Monday, August 7, 2017 at 12:28 PM
To: Raja Aravapalli
Cc: "user@flink.apache.org"
Subject: [EXTERNAL] Re: schema to just read as "byte[] array" from kafka
A quick update, in class MyDe:
publ
A quick update, in class MyDe:
public static class MyDe extends AbstractDeserializationSchema {
@Override
public byte[] deserialize(byte[] arg0) {
// Perform deserialization here, if needed;
// otherwise, probably we can simply return arg0 as raw byte[]
return arg0;
}
}
Chao
Hi Raja,
I just happened to work on the similar thing, and here is how to do it
in general, I think (In my case, I did a bit more, to deserialize a
tuple of ) :
FlinkKafkaConsumer010 consumer = new
FlinkKafkaConsumer010<>("topic_name", new MyDe(), properties);
and for MyDe the schema:
pub
