7.6. バッチコンシューマー

このコンポーネントは、Batch Consumer を実装します。

これにより、たとえば、このバッチに存在するメッセージの数を知ることができ、たとえば、Aggregator にこの数のメッセージを集約させることができます。

コンシューマーは、Amazon Kinesis の特定の単一シャードまたは利用可能なすべてのシャード (複数のシャードの消費) を消費できます。したがって、DSL 設定の 'shardId' プロパティーを空のままにしておくと、使用可能なすべてのシャードが消費されます。そうでない場合は、shardId に対応する指定されたシャードのみが消費されます。