我正在尝试编写一个kafka连接器,将kafka主题中的数据移动到mongodb(接收器)中。因为我已经在连接-json-Standalone.properties文件中添加了所需的配置,而且还在kafka文件夹中的connec-mongo-sink.properties文件中添加了所需的配置。在此过程中,在启动连接器时,我将获得以下异常
[2019-07-23 18:07:17,274] INFO Started o.e.j.s.ServletContextHandler@76e3b45b{/,null,AVAILABLE} (org.eclipse.jetty.server.handler
我在使用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