文章 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 有人知道为什么吗? ...

实时计算 Flink版操作报错合集之使用kafka connector时,报错:java.lang.ClassNotFoundException,是什么原因
文章 2024-07-16 来自:开发者社区

实时计算 Flink版产品使用问题之建了一张upsert-kafka的flink表,但是数据为空,该如何排查

问题一:FlinkCDC版本映射的图有吗? FlinkCDC版本映射的图有吗? 参考答案: 如下图 关于本问题的更多回答可点击进行查看: https:/...

实时计算 Flink版产品使用问题之建了一张upsert-kafka的flink表,但是数据为空,该如何排查

消息队列Kafka入门课程

4 课时 |
3377 人已学 |
免费

分布式消息系统 Kafka 快速入门

24 课时 |
903 人已学 |
免费
开发者课程背景图
文章 2024-07-16 来自:开发者社区

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

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

实时计算 Flink版产品使用问题之在消费Kafka的Avro消息,如何配置FlinkKafka消费者的相关参数
文章 2024-07-16 来自:开发者社区

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

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

实时计算 Flink版产品使用问题之如何实现两个阿里云账号下的Kafka进行数据的互相传输
文章 2024-07-16 来自:开发者社区

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

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

实时计算 Flink版产品使用问题之配置了最大连续失败数不为1,在Kafka的精准一次sink中,如果ck失败了,这批数据是否会丢失
文章 2024-06-17 来自:开发者社区

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

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

实时计算 Flink版操作报错合集之从 PostgreSQL 读取数据并写入 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...

实时计算 Flink版操作报错合集之kafka源表没有指定group.id,遇到报错,该怎么解决
文章 2024-06-16 来自:开发者社区

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

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

实时计算 Flink版产品使用问题之kafka2hive同步数据时,如何回溯历史数据
文章 2024-06-16 来自:开发者社区

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

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

实时计算 Flink版产品使用问题之 从Kafka读取数据,并与两个仅在任务启动时读取一次的维度表进行内连接(inner join)时,如果没有匹配到的数据会被直接丢弃还是会被存储在内存中
文章 2024-06-16 来自:开发者社区

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

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

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

本页面内关键词为智能算法引擎基于机器学习所生成,如有任何问题,可在页面下方点击"联系我们"与我们沟通。

产品推荐

消息队列

消息队列是构建分布式互联网应用的基础设施,通过消息队列实现的松耦合架构设计可以提高系统可用性以及可扩展性,是适用于现代应用的优秀设计方案。

+关注