pyflink.datastream.connectors.elasticsearch.FlushBackoffType

class FlushBackoffType(value)

Used to control whether the sink should retry failed requests at all or with which kind back off strategy.

Data:

CONSTANT:

After every failure, it waits a configured time until the retries are exhausted.

Data:

EXPONENTIAL:

After every failure, it waits initially the configured time and increases the waiting time exponentially until the retries are exhausted.

Data:

NONE:

The failure is not retried.

Attributes

CONSTANT
EXPONENTIAL
NONE