阿里云文档 2025-05-27

调用GetQuotaTip获取Topic和分区的使用配额

获取Topic和分区的使用配额。

阿里云文档 2024-11-21

不同流量规格内Topic和分区的预包含数量是多少

自2022年8月26日起,云消息队列 Kafka 版不再支持按照Topic规格购买实例。

阿里云文档 2024-11-21

Topic分区倾斜怎么办?

问题现象Topic分区倾斜导致部分磁盘水位偏高,无法充分使用所有磁盘性能和容量。Topic分区倾斜导致部分节点流量过高,触发单节点限流。可能原因创建Topic时没有按照推荐的倍数设置分区数。解决方案登录云消息队列 Kafka 版控制台,在左侧导航栏,单击实例列表。云消息队列 Kafka 版控制台云消...

阿里云文档 2024-11-18

如何从Topic规格转换为按照分区规格购买类型

云消息队列 Kafka 版不再支持按照Topic规格购买实例,存量的按照Topic规格购买的实例,也将转换为按照分区规格购买类型。

文章 2024-05-16 来自:开发者社区

实时计算 Flink版产品使用合集之支持sink到多分区的kafka ,还能保持有序吗

问题一:请教下Flink CDC SQL Server用户定义数据类型该怎么处理? 请教下Flink CDC SQL Server用户定义数据类型该怎么处理?目前错误提示IllegalArgumentException: The column "WARD_CODE" is referenced as PRIMARY KEY, but a matching column is n...

问答 2023-11-30 来自:开发者社区

Flink CDC支持sink到多分区的kafka ,还能保持有序吗?

Flink CDC支持sink到多分区的kafka ,还能保持有序吗?

阿里云文档 2023-08-23

如何进行分区均衡引流和Topic分区引流?

本文介绍如何在控制台上进行集群分区均衡引流和Topic分区引流。

问答 2023-06-04 来自:开发者社区

大佬们 请教个问题 在开启flink分区发现Kafka partition的时候,扩分区后会导致任?

大佬们 请教个问题 在开启flink分区发现Kafka partition的时候,扩分区后会导致任务重报错咋回事? java.lang.RuntimeException: One or more fetchers have encountered exception at org.apache.flink.connector.base.source.reader.fetcher.SplitFet....

问答 2022-08-29 来自:开发者社区

这里的分区怎么指定成按照kafka里面的业务字段sendtime发送时间来分区呀?

"dataworks中kafka数据同步到odps表,这里的分区怎么指定成按照kafka里面的业务字段sendtime发送时间来分区呀? "

问答 2018-10-18 来自:开发者社区

hi 我遇到一个奇怪的问题 有一个10个分区的kafka topic 我的并发度设置成9 有8个分区的数据不消费 并发度设置成8有6个分区数据没法消费 并发度设置成10时 所有分区数据都消费不到,但是从日志上来看 每个task 都分配到了一个partition. 并发度设置成2或者5时 数据消费正常

转自钉钉群21789141:hi 我遇到一个奇怪的问题 有一个10个分区的kafka topic 我的并发度设置成9 有8个分区的数据不消费并发度设置成8有6个分区数据没法消费 并发度设置成10时 所有分区数据都消费不到,但是从日志上来看 每个task 都分配到了一个partition. 并发度设置成2或者5时 数据消费正常

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

产品推荐

消息队列

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

+关注