Kafka

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

用DTS从RDS MySQL数据库中同步数据到云Kafka中，增量同步数据延迟时间超过1秒，，连链路规格已经large最高的了，Flink怎么诊断问题出现在哪里呢？或者有没有降低延…

使用数据传输DTS从RDS MySQL数据库中同步数据到云Kafka中，增量同步数据延迟时间超过1秒，，连链路规格已经large最高的了，怎么诊断问题出现在哪里呢？或者有没有降低延…

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

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

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

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

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

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

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

读取kafka直接写入starrocks,flinksql提交，算子合并了看不到读取写入数量计数器的值，有参数把算子分开吗？ 以下为热心网友提供的参考意见 env.disableO…

Flink sql支持批量读kafka么？ 以下为热心网友提供的参考意见 是的，Flink SQL支持批量读取Kafka数据。您可以使用TABLE语句和FROM子句来指定Kafka…