OnCommitFailure

Controls retry and error handling behavior when a committer fails.

committer/coreJavadoc: OnCommitFailure

Notes

Defines how the committer behaves when a commit operation fails. Supports configurable retry counts, retry delays, optional batch splitting on retry, and the ability to ignore non-critical errors to keep processing.

Usage

YAML

ignoreErrors: false
maxRetries: 0
retryDelay: 0
splitBatch: OFF

JSON

{
  "ignoreErrors": false,
  "maxRetries": 0,
  "retryDelay": 0,
  "splitBatch": "OFF"
}

XML

<onCommitFailure>
  <ignoreErrors>false</ignoreErrors>
  <maxRetries>0</maxRetries>
  <retryDelay>0</retryDelay>
  <splitBatch>OFF</splitBatch>
</onCommitFailure>

Properties

Property	Type	Required	Default
ignoreErrors	boolean	No	false
maxRetries	integer	No	0
retryDelay	integer	No	0
splitBatch	enum	No	OFF

Property Details

ignoreErrors

Ignore non-critical errors in an attempt to keep going.

maxRetries

Maximum retries upon commit failures. Default is 0 (does not retry).

retryDelay

Delay in milliseconds between retries. Default is 0 (does not wait).

splitBatch

Whether and how to split batches when re-attempting them, to send them in smaller size. Default does not split.

Allowed Values

• OFF
• HALF
• ONE