The event position to use when claiming a partition if not already initialized.
Defaults to EventPosition.earliest()
The max size of the batch of events passed each time to user code for processing.
The maximum amount of time to wait to build up the requested message count before passing the data to user code for processing. If not provided, it defaults to 60 seconds.
A load balancer to use
Generated using TypeDoc
A set of options to pass to the constructor of
EventProcessor
. You can specifymaxBatchSize
: The max size of the batch of events passed each time to user code for processing.maxWaitTimeInSeconds
: The maximum amount of time to wait to build up the requested message count before passing the data to user code for processing. If not provided, it defaults to 60 seconds.Example usage with default values:
{ maxBatchSize: 1, maxWaitTimeInSeconds: 60 }