flink sql。kafka 接受double为0的数据群,最后变为了0.0 有办法解决吗?

flink sql。kafka 接受double为0的数据群,最后变为了0.0 有办法解决吗?

Flink CDC 如果用sql方式的话中间是不是必须要经历kafka来转换一下呢?

Flink CDC mysql到hive,如果用sql方式的话中间是不是必须要经历kafka来转换一下呢?

消息队列Kafka入门课程

4 课时 |
3098 人已学 |
免费

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

24 课时 |
640 人已学 |
免费
开发者课程背景图

实时计算 Flink版sql1.13 怎么把数据以json格式写入kafka?

实时计算 Flink版sql1.13 怎么把数据以json格式写入kafka?

flink cdc sql方式将mysql同步到kafka时报发下错误,有遇到的吗?

flink cdc sql方式将mysql同步到kafka时报发下错误,kafka是集群模式,有遇到的吗?

flink sql读取kafka数据

kafka数据源中的数据格式是数组格式:[{"a":1,"b":2},{"a":3,"b":1}],flink sql应该如何定义对应的schema去读取数据?

flink sql中使用upsert-kafka作为数据源,请问是什么原因?

flink sql中使用upsert-kafka作为数据源,做一条记录的修改操作后,使用doris-connector向doris中写入的数据会出现修改前和修改后一共2条记录,请问是什么原因?是的,当对1条数据进行修改后,doris中明细模型中就存在1条原始数据 和 新产生1条修改前的原始数据+1条...

flink sql 写数据到kafka,我应该怎么组织数据 写入kafka呢?

flink sql 写数据到kafka,kafka的数据格式json是嵌套的 我应该怎么组织数据 写入kafka呢?

Flink CDC我自定义了一个flink SQL的Kafka分区器,有遇到这个问题的吗?

Flink CDC我自定义了一个flink SQL的Kafka分区器,在写入的时候会报类型转换异常,有遇到这个问题的吗?

请问有flink sql 1.15 从kafka读取数据然后写入clickhouse的示例代码吗

环境说明:flink sql 1.15 on yarn 模式 现在需要去读取kafka的数据,然后写入clickhouse。 请问有示例代码,包括pom.xml文件中需要添加哪些信息吗? 主要是想问下sink表怎么建,pom文件怎么引入依赖

请教大家一个flink sql 消费kafka,开启了checkpoint。topic每个分区都是有

请教大家一个flink sql 消费kafka,开启了checkpoint。topic每个分区都是有数据,现在监控发现,flink作业在提交offset的时候,消费一段时间后,有1个partition的数据offset不提交了,但是这个partition一直有数据

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

社区圈子

消息队列
消息队列
消息队列是构建分布式互联网应用的基础设施,通过消息队列实现的松耦合架构设计可以提高系统可用性以及可扩展性,是适用于现代应用的优秀设计方案。
20+人已加入
加入
相关电子书
更多
任庆盛|Flink CDC + Kafka 加速业务实时化
消息队列 Kafka 版差异化特性
2019大数据技术公开课第五季—kafka 数据如何同步到 MaxCompute
立即下载 立即下载 立即下载