我在使用flink- connector -kafka-0.9连接器运行Flink时出现以下错误。
Exception in thread "main" java.lang.ClassCastException: org.apache.flink.streaming.connectors.kafka.FlinkKafkaProducer cannot be cast to org.apache.flink.streaming.api.functions.source.SourceFunction
at com.dataartisans.ReadFromKafka.main
我在这里看到了用于Java的示例,但是当我在这里查看时,它显示:
def reader(self):
raise NotImplementedError(
'PubSubSource is not supported in local execution.')
那是什么意思?云数据流Python SDK PubSub源/宿还没准备好吗?