Apache Flink:Python流API中的Kafka连接器，“无法加载用户类” - python

我正在尝试Flink的新Python流API，并尝试使用./flink-1.6.1/bin/pyflink-stream.sh examples/read_from_kafka.py运行我的脚本。 python脚本非常简单，我只是想从一个现有的主题中获取内容并将所有内容发送到stdout（或默认情况下output方法在其中发出输出数据的日志目录中的* .ou […]