Hi, Flink 1.18.0 Kafka Connector 3.0.1-1.18 Kafka v 3.2.4 JDK 17
I get error on class org.apache.flink.streaming.runtime.tasks.SourceStreamTask on LegacySourceFunctionThread.run() "java.util.concurrent.CompletableFuture@12d0b74 [Not completed, 1 dependents] I am using the FlinkKafkaConsumer. I dont get this error message on Flink 1.17.1 and JDK 11. Because of the error, the consumed data does no longer enters my process function. Regards, Pat
