用flinksql cdc 直连就行了
https://nightlies.apache.org/flink/flink-docs-release-1.12/dev/table/connectors/kafka.html

看着像是mysql密码初始化了两边,网上有教程,弄一下就好了,我原来遇到过

@青牛 编译过了,看到的内容是一样的,我再试试,谢谢大哥

@青牛
还是不行大哥

mapreduce支持monogdb的

第五步测试访问的图片

防盗链原理图

@青牛 像我何大哥学习

maven build配置部分

UTF-8UTF-81.8Finchley.SR11.1.0.FinalMMddHHmmlib/BOOT-INF/lib/**/*.jarsrc/main/resources**/*.properties**/*.jar**/*.so**/*.xml**/*.tld**/*.yml**/*.xlsfalsesrc/main/java**/*.properties**/*.yml**/*.xml**/*.tldfalseorg.springframework.bootspring-boot-maven-pluginorg.codehaus.mojobuildnumber-maven-plugin1.4yyyyMMddcreate-timestampfalse${project.artifactId}-${project.version}-${timestamp}