Hi, patricia. Can you attach full stack about the exception. It seems the thread reading source is stuck.
-- Best! Xuyang At 2023-11-23 16:18:21, "patricia lee" <plee3...@gmail.com> wrote: 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