Package io.aiven.kafka.connect.common.config

Class BackoffPolicyConfig

java.lang.Object

io.aiven.kafka.connect.common.config.ConfigFragment

io.aiven.kafka.connect.common.config.BackoffPolicyConfig

public class BackoffPolicyConfig
extends ConfigFragment

Defines the backoff policy for connectors.

Field Summary

Fields inherited from class io.aiven.kafka.connect.common.config.ConfigFragment

cfg

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	BackoffPolicyConfig(org.apache.kafka.common.config.AbstractConfig cfg)

Method Summary

Modifier and Type	Method	Description
Long	getKafkaRetryBackoffMs()	Gets the kafka retry backoff time..
static org.apache.kafka.common.config.ConfigDef	update(org.apache.kafka.common.config.ConfigDef configDef)	Adds configuration options to the configuration definition.

Methods inherited from class io.aiven.kafka.connect.common.config.ConfigFragment

has, validate

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

BackoffPolicyConfig

protected BackoffPolicyConfig(org.apache.kafka.common.config.AbstractConfig cfg)

Method Details

update

public static org.apache.kafka.common.config.ConfigDef update(org.apache.kafka.common.config.ConfigDef configDef)

Adds configuration options to the configuration definition.

Parameters:

configDef - the configuration definition ot update.

Returns:

the configuraiton definition with additional options.

getKafkaRetryBackoffMs

public Long getKafkaRetryBackoffMs()

Gets the kafka retry backoff time..

Returns:

the Kafka retry backoff time in MS.