我在使用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源/宿还没准备好吗?
我读了一本书"kubernetes in action",书中提到了“云提供商上的侵入控制器(例如,在GKE中)要求In宿指出一个NodePort服务”。
当Ingress控制器从服务本身获取Pod并将请求直接路由到IP和端口时,它为什么需要NodePort服务?节点的IP和端口(由NodePort服务提供)用于什么?