kafka是其他部门的,如果是在kafka source算子那有背压,怎么加以区分呢?

kafka是其他部门的,如果是在kafka source算子那有背压,怎么加以区分呢?

展开
收起
云上静思 2022-08-02 11:25:21 459 分享 版权
1 条回答
写回答
取消 提交回答
  • 从kafka source开始,加个rescale,然后kafka 后边那个算子的并行度扩大至kafka分区数的1.5倍。如果还有背压。就加分区去吧。

    此答案来自钉钉群“Serverless 开发者技术学习群”

    2022-08-02 11:52:22
    赞同 展开评论

涵盖 RocketMQ、Kafka、RabbitMQ、MQTT、轻量消息队列(原MNS) 的消息队列产品体系,全系列产品 Serverless 化。RocketMQ 中文社区:https://rocketmq-learning.com/

收录在圈子:
+ 订阅
专注 Serverless、微服务、函数计算、Serverless 应用引擎、云原生技术
还有其他疑问?
咨询AI助理