Lambda `Batch Window` 的 AWS MSK 触发器，如配置

Answer 1

是的，有一个选项可以设置批处理窗口用于 MSK 触发器。创建触发器时，您可以在 lambda 控制台上自行设置批处理窗口和批处理大小。 在内部，它是一个事件源映射，它使用这些设置轮询来自主题的消息。想象一个内部消费者正在消费这些消息，一旦达到阈值，另一个进程就会调用 lambda 函数。 这里的阈值可以定义为：

1. 达到设置的批量大小。
2. 或到达批处理窗口。
3. 或收集的事件大小达到 6MB。在这种情况下，最后一条消息被丢弃并在下一批中轮询。

   PS：通过事件源映射的事件轮询是一个同步的过程。只要 lambda 没有成功退出执行，就不会提交整个批偏移量。它会在此持续时间内阻止该特定分区上的执行。

   来自 AWS Docs- https://aws.amazon.com/blogs/compute/introducing-aws-lambda-batching-controls-for-message-broker-services/