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.
Called when we stop processing events from a partition.
Called when errors occur during event receiving.
Called when we first start processing events from a partition.
Generated using TypeDoc
Options for subscribe.