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

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

实时计算 Flink版操作报错合集之使用kafka connector时，报错：java.lang.ClassNotFoundException，是什么原因

问题一：Flink使用 kafka connector 报错 Caused by:有人知道为什么吗？ Flink使用 kafka connector 报错 Caused by: java.lang.ClassNotFoundException: org.apache.flink.connector.kafka.source.KafkaSource 有人知道为什么吗？ ...

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

实时计算 Flink版产品使用问题之在消费Kafka的Avro消息，如何配置FlinkKafka消费者的相关参数

问题一：FlinkSQL消费avro格式的kafka消息，这两个配置 Kafka消费者应该怎么配置啊? FlinkSQL消费avro格式的kafka消息，，想用DataStreamAPi方式消费，这两个配置 Kafka消费者...

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

实时计算 Flink版产品使用问题之如何实现两个阿里云账号下的Kafka进行数据的互相传输

问题一：大佬们，flink怎么使用呢？项目空间创建好了，点进去啥也没有。大佬们，flink怎么使用呢？项目空间创建好了，点进去啥也没有。参考答案：参考这个找 owner 授权使用 ...

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

实时计算 Flink版产品使用问题之配置了最大连续失败数不为1，在Kafka的精准一次sink中，如果ck失败了，这批数据是否会丢失

问题一：Flink如果我配置了最大连续失败数不为 1 那么如果我 ck 失败了我这批数据会丢失吗？ Flink中kafka 的精准一次 sink 如果我配置了最大连续失败数不为 1 那么如果我 ck 失败了我这批数据会丢失吗？参考答案：如果你配置了最大连续失败数不为1，那么在Flink中Kafka的精准一次sink中，如果ck失败了，这批数据不...

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

在Flink CDC中我的场景是把变更数据抽到Kafka进行实时计算，这种脏数据应该咋处理？

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

实时计算 Flink版操作报错合集之从 PostgreSQL 读取数据并写入 Kafka 时，遇到 "initial slot snapshot too large" 的错误，该怎么办

问题一：Flink CDC中mysql cdc采集的时候，这个监控没有值是为什么呢？ Flink CDC中mysql cdc采集的时候，这个监控没有值是为什么呢？参考回答：关于本问...

文章 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版产品使用问题之从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...