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.
Free forum by Nabble | Edit this page |