Maybe you can check the kafka connector version and make sure the jar is in the lib dic. https://nightlies.apache.org/flink/flink-docs-release-1.20/docs/connectors/datastream/kafka/
> 2024年12月3日 19:36，Stefano Braga <s.br...@antgroup.it> 写道： > > py4j.protocol.Py4JJavaError: An error occurred while calling o0.execute. > : java.net.MalformedURLException: no protocol
