暂无个人介绍
2024年01月
2023年12月
jdbc的依赖包问题,参考官方文档或者一些技术网站时,引入的jdbc依赖是
解决方法:将以上jdbc依赖删除,换成如下依赖,并将下载后的依赖传到flink集群的各个节点的lib目录下并重启集群服务
是引入的依赖包造成的,刚开始参考官方文档引入kafka依赖时,项目的pom文件引入的是flink-connector-kafka,而不是flink-sql-connector-kafka,修改pom文件如下即可,同时要将对应的jar包上传到flink集群各节点的lib包下并重启集群
此外,kafka上的主题名称不要使用下划线,否则会报类似如下的错误: