Module io.aiven.commons.kafka.config

Package io.aiven.commons.kafka.config.fragment

Class BackoffPolicyFragment

java.lang.Object

io.aiven.commons.kafka.config.fragment.ConfigFragment

io.aiven.commons.kafka.config.fragment.BackoffPolicyFragment

All Implemented Interfaces:

FragmentDataAccess

public final class BackoffPolicyFragment
extends ConfigFragment

Defines the backoff policy for connectors.

Field Summary

Fields inherited from class io.aiven.commons.kafka.config.fragment.ConfigFragment

dataAccess

Constructor Summary

Constructors

Constructor	Description
BackoffPolicyFragment(FragmentDataAccess dataAccess)	Constructor.

Method Summary

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

Methods inherited from class io.aiven.commons.kafka.config.fragment.ConfigFragment

getBoolean, getConfiguredInstance, getInt, getList, getLong, getPassword, getString, has, logDeprecated, logDeprecated, logDeprecated, registerIssue, validate, validate, validationMessage, values

Methods inherited from class java.lang.Object

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

Constructor Details

BackoffPolicyFragment

public BackoffPolicyFragment(FragmentDataAccess dataAccess)

Constructor.

Parameters:

dataAccess - The data to access.

Method Details

update

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

Adds configuration options to the configuration definition.

Parameters:

configDef - the configuration definition ot update.

Returns:

the number of items in the backoff policy group.

getKafkaRetryBackoffMs

public Long getKafkaRetryBackoffMs()

Gets the kafka retry backoff time.

Returns:

the Kafka retry backoff time in MS.