Hi Colleagues,I get this exception at runtime...Any ideas pls?Thanks
java.lang.UnsupportedOperationException: The transform KafkaIO.Read [KafkaIO.TypedWithoutMetadata] is currently not supported. at org.apache.beam.runners.flink.translation.FlinkStreamingPipelineTranslator.visitTransform(FlinkStreamingPipelineTranslator.java:106)
