云消息队列 Kafka 版产品的相关内容

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

DataWorks产品使用合集之如何离线增量同步Kafka数据，并指定时间范围进行同步

问题一：dataworks为什么在Datastudio中看不到odps sql的新建节点菜单？ dataworks为什么在Datastudio中看不到odps sql的新建节点菜单？参考回答： https://help.aliyun.com/zh/dataworks/user-guide/create-a-maxcompute-data-source...

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

AutoMQ 产品动态 | 发布 1.1.0，兼容至 Apache Kafka 3.7，支持 Kaf

2024年05-06月动态 01 云原生 Kafka 内核 AutoMQ 发布 1.1.0 版本，兼容 Apache Kafka 到 3.7 版本。 AutoMQ 采用存算分离的思路重构 Apache Kafka，计算层 100% 保留 Kafka 代码，可以更好、更快地适配 Apache Kafka 新版本。经过代码 Review、Chaos 测试和 500+ E2E 长时间验证，...

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

Serverless 应用引擎产品使用合集之如何触发kafka

问题一：Serverless 应用引擎切换新版页面空白是为什么? Serverless 应用引擎切换新版页面空白是为什么? 参考答案：应该是arms 监控页面切换有点问题，这个后面版本会拉齐体验哈...

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

DataWorks产品使用合集之如何处理Kafka数据

问题一：DataWorks能告诉我甘特图中的近期均值，是怎么计算出来的么？ DataWorks能告诉我甘特图中的近期均值，是怎么计算出来的么？参考回答：正常应该是根据历史运行情况计算出预估的完成时间如果您这里一直固定是5分钟就需要单独排查看下了关于本问题的更多回答可点击原文查看：https://developer.aliyu...