云消息队列 Kafka 版

Flink执行CREATE TABLE AS（CTAS）语句报错这个错，怎么解决？说这个表中kafka catalog中不存在，就是想执行这个语句创建这个表

数据传输DTS这个错是啥问题啊？2023-12-22 19:25:05 [com.aliyun.dts.subscribe.clients.recordfetcher.KafkaR…

请教下数据传输DTS订阅数据变更消息，client启动时报这个错误是什么原因？订阅配置检查过都没有问题。2023-12-21 12:10:09.816 INFO 77013 &#8…

关于Flink弹性扩缩容有个疑问：比如Kafka12个分区，Flink任务（KafkaSource -> Process -> BDSink）On Yarn appli…

机器学习PAI这个问题怎么解决？利用官方的webui教程，容器搭建了一套，在webui上配置了一个csv到kafka的流程，一直报kafka的factory找不到。 以下为热心网友…

flink 消费kafka,之前任务正常的，突然有个分区没法消费了，重启下任务久正常了？

数据传输DTS网络抖动等原因导致当前数据写入模块连接缓存模块超时？【UID】：30480957【Job ID】：ztb128cpa4l782f【任务名称】：dtsglx8wctz【…

Flink这个错误是为什么发生？从kafka往Doris sink数据时候报错， 偏移量还是自动提交了，导致修复后启动消费，那条错误的数据丢失了，没有消费到。 以下为热心网友提供的…

使用flink sql 的lookup join，一边是kafka流表，一边是mysql维表，我启用了cache，有什么办法让flink只查询cache的数据，如果查不到就直接输出…

在阿里函数计算里请问Terraform 怎么创建 trigger？kafka 触发函数计算 以下为热心网友提供的参考意见 Kafka触发器https://help.aliyun.c…

【UID】：1869047806262459【Job ID】：i2hz5y0t2094bct【任务名称】：生产环境mysql数据库同步【所有报错信息】： CODE：DTS-RETR…

有没有大佬测试过flink拉取kafka的单topic速度极限是多少？我这边测的是20多M每秒，还能再提高吗？我现在是单topic单partition 以下为热心网友提供的参考意见…