schema to just read as "byte[] array" from kafka

Posted by Raja.Aravapalli on
URL: http://deprecated-apache-flink-user-mailing-list-archive.369.s1.nabble.com/schema-to-just-read-as-byte-array-from-kafka-tp14725.html

 

Hi

 

I am using SimpleStringSchema to deserialize a message read from kafka, but need some help to know if there is any schema available I can use rather than “SimpleStringSchema()” and instead just get “byte[]” without any deserialization happening!

 

Below is code I am currently using, but instead of SimpleStringSchema() which is giving me Strings, but I want the a raw byte array Byte[]:

 

FlinkKafkaConsumer08<String> myConsumer = new FlinkKafkaConsumer08<>("xxx_topic", new SimpleStringSchema(), properties);

 

 

Thanks a lot.

 

 

Regards,

Raja.