云消息队列 Kafka 版
-
读取kafka直接写入starrocks,flinksql提交,有参数把算子分开吗?-[阿里云_云淘科技]
读取kafka直接写入starrocks,flinksql提交,算子合并了看不到读取写入数量计数器的值,有参数把算子分开吗? 以下为热心网友提供的参考意见 env.disableO…
-
Flink sql支持批量读kafka么?-[阿里云_云淘科技]
Flink sql支持批量读kafka么? 以下为热心网友提供的参考意见 是的,Flink SQL支持批量读取Kafka数据。您可以使用TABLE语句和FROM子句来指定Kafka…
-
有小伙伴可以提供下 flinkcdc读mysql写kafka表的pom吗?-[阿里云_云淘科技]
有小伙伴可以提供下 flinkcdc读mysql写kafka表的pom吗? 以下为热心网友提供的参考意见 当使用Flink CDC从MySQL读取数据并将其写入Kafka时,您需要…
-
Flink写入阿里云的selectdb,导入selectdb连接器报错,怎么处理? -[阿里云_云淘科技]
Flink写入阿里云的selectdb,导入selectdb连接器报错,怎么处理?用的flinksql从阿里云kafka导入到阿里云selectdb 以下为热心网友提供的参考意见 …
-
数据传输DTS的kafka怎么老是连不上呢?-[阿里云_云淘科技]
数据传输DTS的kafka怎么老是连不上呢? 以下为热心网友提供的参考意见 数据传输服务DTS的Kafka连接问题可能有以下几个原因: 带宽被占满:当DTS的Kafka数据源被多个…
-
数据传输DTS有遇到过类似错误吗?-[阿里云_云淘科技]
数据传输DTS有遇到过类似错误吗?,[2023-11-29 14:00:01.045] [WARN ] [com.aliyun.dts.subscribe.clients.reco…
-
数据传输DTS最近服务费重启的时候偶然会出现 有知道原因麽?-[阿里云_云淘科技]
数据传输DTS最近服务费重启的时候偶然会出现{isOk=false, errMsg=’build kafka consumer failed, error: com.a…