IRecordProcessor
Represents a processor that is responsible for processing any records received from the stream.
Instance members
| Instance member | Description |
OnMaxRetryExceeded(...)
Signature: (records:Record [] * errorHandlingMode:ErrorHandlingMode) -> unit
Modifiers: abstract |
This method is called when we have exceeded the number of retries for a record |
Process(shardId, records)
Signature: (shardId:string * records:Record []) -> ProcessRecordsResult
Modifiers: abstract |
Process a batch of record |
