云消息队列 Kafka 版源表的相关内容

问答 2024-08-12 来自：开发者社区

在Flink CDC中，2个kafka的源表，相差100毫秒，如何保证两者得到结果输出？

在Flink CDC中，2个kafka的源表，相差100毫秒，如何保证两者一定能inner join起来得到结果输出？

文章 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-02-25 来自：开发者社区

Flink因为源表的字段发生更改，请问对应的kafka topic，是否需要删掉重建呢？

问答 2022-12-20 来自：开发者社区

Flink配置消息队列Kafka源表时，Kafka集群需要SASL（Simple Authentic

Flink配置消息队列Kafka源表时，Kafka集群需要SASL（Simple Authentication and Security Layer）认证，此时DDL with参数应该怎么配置

问答 2022-12-16 来自：开发者社区

Flink的Kafka源表消费位点如何设置

文章 2022-11-05 来自：开发者社区

使用Flink 读取kafka Catalog 源表数据展开json写入下游hologres表示例操作

本文主要介绍如何使用Flink  读取kafka Catalog 源表数据写入下游hologres存储，并演示'json.infer-schema.flatten-nested-columns.enable参数，递归的展开JSON中的嵌套列的效果。一准备工作本文测试使用阿里云消息队列Kafka版进行演示，依据Flink集群的网络环境（VPC），构建相关上下游数据源，并做好白明单访问....

问答 2022-10-24 来自：开发者社区

有遇到过从oracle抽数到kafka，源表新增字段后从savepoint重启任务导致kafka里新

有遇到过从oracle抽数到kafka，源表新增字段后从savepoint重启任务导致kafka里新增字段值为空的问题嘛?

问答 2022-10-24 来自：开发者社区

我用kafka-upsert作为源表, 数据格式为键值格式为 'key '/ 'value.for

我用kafka-upsert作为源表, 数据格式为键值格式为 'key '/ 'value.format' = 'csv', Flink去消费时kafka时因为有字段为空值, 报了一个异常: Caused by: java.lang.NumberFormatException: For input string: ""文山请问这种情况下有没有什么参数可以处理它?

文章 2022-06-07 来自：开发者社区

FlinkSQL使用DDL语句创建kafka源表

在Flink1.9.x版本中,社区版本的 Flink 新增了一个 SQL DDL 的新特性，但是暂时还不支持流式的一些概念的定义,比如说水位(watermark). 下面主要介绍一下怎么使用DDL创建kafak源表.定义create table语句从kafka中读取数据 """ |CREATE TABLE PERSON ( | na...