问扩展AWS Kinesis流并提高消费者端性能

EN

Kinesis使用者应该非常快速地使用数据，就像您正确地使用KCL一样，它实际上会对转发到使用者进程的数据进行批量处理。回答您的问题：

1. 确保您在您的消费者上使用“推送模式”。这意味着AWS将处理尽可能多的记录，以减少网络IO并实现快速处理。在我的应用程序中，它一次可以批处理700条记录，从而确保快速处理。有关推送/拉取模型的详细信息，请参阅link here。
2. 有用于自动伸缩分片的ad-hoc解决方案(不确定您现在是否可以通过kinesis直接自动伸缩)，但是您可能希望监控每个分片的指标，例如MillsBehindLatest，这将在消费者端。然而，这会变得很棘手，因为您需要检查流中的每个分片。此外，您还需要监视生产者端以及

我的观点是保持简单，只需提供足够的容量，因为Kinesis甚至能够在几个分片上处理大量数据，并提供几个实例来处理不同可用区中的数据。随着数据的不断调整，增加分片数/实例数。