#1 楼
CloudWatch绝对是走这条路的方法，您可以通过以下方法在CloudWatch中浮出Kafka指标：生产者，消费者或流处理器将所需的指标推送到CloudWatch。您遵循的过程将大致分为：
发布自定义指标。
创建AutoScaling启动配置。
根据您的自定义指标创建一个AutoScaling组和策略。
根据您的费用模型，我还将考虑如何使用竞价型实例以降低成本，即，如果您具有非关键但计算量很大的工作负载，请使用竞价型实例作为自动缩放配置的一部分。
评论
第一个链接已死
–马奎斯·布朗特（Marquis Blount）
17年11月8日在17:30
@MarquisBlount这是页面的Google缓存
– danielhklein
17年12月14日在0:12
评论
也许您可以解释一下为什么您认为cloudwatch不是一个好方法？我的应用程序不受CPU，磁盘I / O或CloudWatch提供的任何其他指标的约束；约束是应用程序能够根据传入的Kafka主题进行处理。