Hi, I have a void function that takes a String, parse it and write it into Cassandra (Using pure java, not Flink Cassandra connector). Using Apache Flink Kafka connector, I've got some data into DataStream<String>. Now I want to apply Parse function to each message in DataStream<String>, but as the Parse function returns nothing (is void), I got the error no instance of type variable R exists so that void conforms to R
Is there any way to do such process using apache Flink?
