问答 2024-07-31 来自:开发者社区

jar作业的方式,kafka作为source 是只要有消息投递 flink这边就会消费么?

jar作业的方式,kafka作为source 是只要有消息投递 flink这边就会消费么? 还是说要等待savepoint的刷新?

问答 2024-06-05 来自:开发者社区

在Flink CDC中配置文件同步方式,没有kafka管道jar包,怎么办?

在Flink CDC中配置文件同步方式,没有kafka管道jar包,怎么办?

问答 2024-05-28 来自:开发者社区

flink-cdc kafka的连接器jar包去哪里下载呀?

flink-cdc kafka的连接器jar包去哪里下载呀?

问答 2024-04-15 来自:开发者社区

Flink CDC里上游pg 下游kafka,提示这个错误是我传的插件jar包有问题的吗?

$stringUtil.substring( $!{XssContent1.description},200)...

问答 2023-11-06 来自:开发者社区

flink 消费kafka数据,idea能正常消费,但是提交flink的jar包运行还是报这个错?

$stringUtil.substring( $!{XssContent1.description},200)...

问答 2023-09-06 来自:开发者社区

Flink CDC是不是和kafka的jar包冲突了,咋处理呢?

Flink CDC是不是和kafka的jar包冲突了,咋处理呢?

问答 2023-07-19 来自:开发者社区

请问Flinkcdc中kafka和upsert kafka的连接器jar包是同一个吗?

请问Flinkcdc中kafka和upsert kafka的连接器jar包是同一个吗?

问答 2022-08-03 来自:开发者社区

提交的job有使用kafka自定义序列化器有用到第三方jar包,提交job的时候出现异常,有大佬帮

提交的job有使用kafka自定义序列化器有用到第三方jar包,提交job的时候出现异常,有大佬帮帮看看吗

问答 2022-08-01 来自:开发者社区

kafka写入到mysql的jar包取消作业后再次run报这个错,得重启taskmanage才行,大

kafka写入到mysql的jar包取消作业后再次run报这个错,得重启taskmanage才行,大佬们这个咋解决?

本页面内关键词为智能算法引擎基于机器学习所生成,如有任何问题,可在页面下方点击"联系我们"与我们沟通。