备案控制台

开发者社区

开发者社区 > 云原生 > 消息队列 > 正文

消息队列量级特别如何优化消费？

hi, 由于消息队列量特别大，在flink接入以后被压严重。除了修改并行度以外还有没有其他的优化方案!!!*来自志愿者整理的flink邮件归档

展开

收起

EXCEED 2021-12-01 15:42:22 684 0

1 条回答

写回答

取消提交回答

彗星halation

被压严重一般是sink 效率低或者计算过程有瓶颈，被压跟数据源数据多少没什么关系。你可以在web 界面查看哪个算子导致的，然后优化就可以了*来自志愿者整理的flink邮件归档

2021-12-01 16:04:40

赞同展开评论打赏

问答分类：

消息中间件流计算实时计算 Flink版

问答标签：

消息队列优化消息队列消费

问答地址：

开发者社区 > 云原生 > 消息队列 > 问答

版权声明：本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。

相关问答

采集 MetaQ 消息队列优化慢接口解决方案的优点是什么？

274

1

0

请问，消息队列的，通过函数计算怎么消费？

608

1

0

采集MetaQ消息队列优化慢接口解决方案的优点有哪些？

1444

1

0

消息队列使用时为了保证消息至少被消费一次，RocketMQ服务端在网络恢复后，会收到相同的消息吗？

814

1

0

java应用使用kafka消息队列异步处理数据，但发送消息时偶尔会有卡住的性能问题，该如何优化？

3300

0

0

redis做了一个简单消息队列，在消费队列执行的时候遇到异常，消费队列停止执行，如何继续？?报错

1183

1

0

MNS如何保证多个消息的消费者访问同一消息队列，而不会丢失消息或重复消费消息？

1949

2

0

消息队列 RocketMQ 版如何添加消费堆积告警？

815

1

0

消息队列 RocketMQ 版消息轨迹没有显示消费信息,为什么？

1514

1

0

消息队列 RocketMQ 版客户端如何设置消费线程数？

1959

1

0

云原生

消息队列

多个子产品线联合打造金融级高可用消息服务以及对物联网的原生支持，覆盖多行业。

我要提问

热门讨论

热门文章

为什么mqtt 连接一直显示 Not authorized to connect ？用的官网示例。

rocketmq客户端日志路径/root/logs/rocketmqlogs，怎么修改或者关闭日志?

请教下 mqtt连接成功了，能收到消息，后面又自动断开了连接，是什么情况？

rocketmq5.x版本删除消息怎么搞，除了定时清理过期消息机制？

在Apache RocketMQ中这种情况队列数量应该设置多少比较合理呢？

消息队列 MQClientException: Send [3] times, still failed

rocketmq 超过4M消息体怎么发送

Apache RocketMQ中consumeThreadMax 消费者最大线程数怎么理解？如果

大佬们，问个问题：rocketmqListener如何selectorexpression动态设置？

MQTT保持连接的话, 应该设置成多少?

展开全部

利用消息队列MQTT，打造一款属于自己的IM社交软件

Aliware-MQ消息队列技术架构与最佳实践

什么是消息队列？

消息队列的exclusive consumer功能是如何保证消息有序和防止脑裂的

为什么需要消息队列，及使用消息队列的好处？

【vue】项目使用mqtt消息队列实现推送

基于TableStore构建简易海量Topic消息队列

消息队列服务Kafka揭秘：痛点、优势以及适用场景

MQ消息队列.NET SDK的使用

Redis笔记（七）Java实现Redis消息队列

展开全部

相关课程

更多

消息队列Kafka入门课程

3098

4

去学习

消息队列RocketMQ 5.0 云原生架构升级课程

4658

8

去学习

消息队列 RocketMQ 全类型业务消息学习课程

2008

2

去学习

消息队列 RocketMQ 消息集成

331

8

去学习

消息队列 MNS 入门课程

2268

9

去学习

使用Redis消息队列完成秒杀过期订单处理

604

15

去学习

相关电子书

更多

企业互联网架构之消息队列 立即下载

基于消息队列RocketMQ的大型分布式应用上云最佳实践 立即下载

云原生消息队列Apache RocketMQ 立即下载

相关实验场景

更多