You are viewing a plain text version of this content. The canonical link for it is here.

Posted to user@flink.apache.org by 闵中元 <mi...@bytedance.com> on 2024/12/03 12:00:01 UTC

Re: [External] Kafka connector and Python

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....@antgroup.it> 写道：
> 
> py4j.protocol.Py4JJavaError: An error occurred while calling o0.execute.
> : java.net.MalformedURLException: no protocol

Re: [External] Kafka connector and Python

Posted by Dian Fu <di...@gmail.com>.

Similar issue reported in slack:
https://apache-flink.slack.com/archives/C03G7LJTS2G/p1736405517356729

It was solved by correcting the java version.

[image: image.png]

On Tue, Dec 3, 2024 at 8:01 PM 闵中元 <mi...@bytedance.com> wrote:

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