Hello Most examples available still use the FlinkKafkaConsumer unfortunately. I need to consume events from Kafka. The format is Long,Timestamp,String,String.
Do I need to create a custom deserializer? What also confuses me is KafkaSource*<String>* source = KafkaSource.... How does it relate to the deserializer? Is there a kind of <Row> type or is <String> fine even if the message is a composite of Long,String...? Regards Hans
