实时计算云消息队列 Kafka 版的相关内容

文章 2024-06-17 来自：开发者社区

实时计算 Flink版操作报错合集之kafka源表没有指定group.id，遇到报错，该怎么解决

问题一：Flink这个bug同步修复过吗？ Flink这个bug同步修复过吗？参考回答：试下这个参数，将 debezium这个参数 "connect.keep.alive.interval.ms" 设置为 30000 试下。关于本问题的更多回答可点击原文查看：https://developer.aliyun.com/ask/614523...

文章 2024-06-16 来自：开发者社区

实时计算 Flink版产品使用问题之kafka2hive同步数据时，如何回溯历史数据

问题一：flink中，join如果不指定窗口，会把join结果一直存储下来吗？ flink中，join如果不指定窗口，会把join结果一直存储下来吗？参考答案： Apache Flink 中，如果不指定窗口进行 join，join 结果不会无限期地存储下来。在无窗口的情况下进行 join，Flink 会根据数据流的到达顺序和关联键进行即时 join。...

文章 2024-06-16 来自：开发者社区

实时计算 Flink版产品使用问题之从Kafka读取数据，并与两个仅在任务启动时读取一次的维度表进行内连接（inner join）时，如果没有匹配到的数据会被直接丢弃还是会被存储在内存中

问题一：Flink CDC 里这个配置参数有文档吗？哪里有全部的配置参数可以查到？ Flink CDC 里这个配置参数有文档吗？哪里有全部的配置参数可以查到？ https://github.com/apache/flink-cdc ...

文章 2024-06-16 来自：开发者社区

实时计算 Flink版产品使用问题之通过flink同步kafka数据进到doris,decimal数值类型的在kafka是正常显示数值，但是同步到doris表之后数据就变成了整数，该如何处理

问题一：Flink如果sink表建表字段过短，有数据不能插入，有啥策略配置能丢弃这些不合格的数据吗？ Flink如果sink表建表字段过短，有数据不能插入，有啥策略配置能丢弃这些不合格的数据吗？ configuration.set(ExecutionConfigOptions.TABLE_EXEC_SINK_TYPE_LENGTH_ENFORCER, ExecutionConfi...

文章 2024-06-15 来自：开发者社区

实时计算 Flink版产品使用问题之如何实现OSS数据到Kafka的实时同步

问题一：Flinkcdc支持从Oracle备库抽取数据么？ Flinkcdc支持从Oracle备库抽取数据么？参考答案：支持关于本问题的更多回答可点击进行查看： https://developer.aliyun.com/ask/607306 问题二：flink cdc 读取多个表，，...

问答 2024-06-15 来自：开发者社区

实时计算Flink如何消费kafka

文章 2024-05-23 来自：开发者社区

实时计算 Flink版产品使用合集之如何批量读取Kafka数据

问题一：Flink sql支持批量读kafka么？ Flink sql支持批量读kafka么？参考答案：是的，Flink SQL支持批量读取Kafka数据。您可以使用TABLE语句和FROM子句来指定Kafka作为数据源，并使用GROUP BY或JOIN等操作对数据进行处理。以下是一个示例Flink SQL查询，演示如何从Kafka中批量...

文章 2024-05-23 来自：开发者社区

实时计算 Flink版产品使用合集之使用DTS从RDSMySQL数据库同步数据到云Kafka，增量同步数据延迟时间超过1秒。如何诊断问题并降低延迟

问题一：Flink 1.17.1 Join维表时，对维表字段where过滤或维表中维表字段这种会有问题吗？ Flink 1.17.1 Join维表时，对维表字段where过滤或维表中Join ... on ... and 维表字段这种会有问题吗？参考答案：在Flink 1.17.1中，对维表字段进行WHERE过滤或者在JOIN语句中使用...