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 写道：
>
> py4j.protocol.Py4JJavaError: An error occurred while calling o0.execute
Hello everyone,
I'm relatively new to Flink (currently exploring the documentation and
experimenting with it).
I'm using Flink version 1.20 (with the Python package apache-flink 1.20.0 and
the right Kafka connector jar), and I've been struggling with an issue for the
past week.
I wrote a simple
