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

文章 2024-08-29 来自：开发者社区

实时计算 Flink版产品使用问题之如何使用Kafka Connector将数据写入到Kafka

问题一：Flink CDC里之前用mysql数据库join比较慢，这种join性能会比较好吗？ Flink CDC里之前用mysql数据库join比较慢，所以才改成同步宽表到es，不知道doris，starorcks 这种join性能会比较好吗？参考答案： Flink CDC 主要用于捕获和处理数据库变更数据流，而不是直接优化JOIN操作。MySQL...

文章 2024-08-29 来自：开发者社区

实时计算 Flink版产品使用问题之处理Kafka数据顺序时，怎么确保事件的顺序性

问题一：Flink CDC里从kafka消费的时候顺序会乱，这时候就无法区分顺序了，这种情况有办法处理吗？ Flink CDC里从kafka消费的时候顺序会乱，这时候就无法区分顺序了，这种情况有办法处理吗？flink开窗排序可以解决，但遇到两个操作时间在同一时刻的咋办呢，有其它字段可以作标识区分吗？flink cdc到kafka是顺序的，但如果其中一条消息出现失败后重试，不会出现顺序问题...

文章 2024-08-18 来自：开发者社区

实时数仓 Hologres产品使用合集之如何用python将kafka数据写入

问题一：Hologres holo里可以用python将kafka数据写入吗？还是说只有java的？ Hologres holo里可以用python将kafka数据写入吗？还是说只有java的？参考答案： https://help.aliyun.com/zh/hologres/developer-reference/sdk-for-python?...

文章 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版产品使用问题之建了一张upsert-kafka的flink表，但是数据为空，该如何排查

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

文章 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 长时间验证，...