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.