Class PollingRemoteConfigurationConfig

java.lang.Object

org.apache.kafka.common.config.AbstractConfig

io.confluent.telemetry.config.remote.RemoteConfigConfiguration

io.confluent.telemetry.config.remote.polling.PollingRemoteConfigurationConfig

Direct Known Subclasses:

FileRemoteConfigConfiguration, KubernetesRemoteConfigurationConfig

public class PollingRemoteConfigurationConfig
extends RemoteConfigConfiguration

Field Summary

Fields

Modifier and Type	Field	Description
static final int	DEFAULT_MAX_RETRY_ATTEMPTS
static final Long	DEFAULT_REFRESH_INTERVAL
static final double	DEFAULT_RETRY_BACKOFF_MULTIPLIER
static final long	DEFAULT_RETRY_INITIAL_DELAY_MS
static final long	DEFAULT_RETRY_MAX_DELAY_MS
static final String	MAX_RETRY_ATTEMPTS_CONFIG
static final String	MAX_RETRY_ATTEMPTS_DOC
static final String	REFRESH_INTERVAL_MS_CONFIG
static final String	REFRESH_INTERVAL_MS_DOC
static final String	RETRY_BACKOFF_MULTIPLIER_CONFIG
static final String	RETRY_BACKOFF_MULTIPLIER_DOC
static final String	RETRY_INITIAL_DELAY_MS_CONFIG
static final String	RETRY_INITIAL_DELAY_MS_DOC
static final String	RETRY_MAX_DELAY_MS_CONFIG
static final String	RETRY_MAX_DELAY_MS_DOC

Fields inherited from class RemoteConfigConfiguration

DEFAULT_ENABLED, ENABLED_CONFIG, ENABLED_CONFIG_DOC

Fields inherited from class org.apache.kafka.common.config.AbstractConfig

AUTOMATIC_CONFIG_PROVIDERS_PROPERTY, CONFIG_PROVIDERS_CONFIG, CONFIG_PROVIDERS_DOC

Constructor Summary

Constructors

Constructor	Description
PollingRemoteConfigurationConfig(Map<?,?> originals, boolean doLog)
PollingRemoteConfigurationConfig(org.apache.kafka.common.config.ConfigDef config, Map<?,?> originals, boolean doLog)	Constructor for child classes

Method Summary

Modifier and Type	Method	Description
static org.apache.kafka.common.config.ConfigDef	defineConfigs(org.apache.kafka.common.config.ConfigDef base)
int	getMaxRetryAttempts()
Long	getRefreshInterval()
double	getRetryBackoffMultiplier()
long	getRetryInitialDelayMs()
long	getRetryMaxDelayMs()

Methods inherited from class RemoteConfigConfiguration

isEnabled

Methods inherited from class org.apache.kafka.common.config.AbstractConfig

documentationOf, equals, getBoolean, getClass, getConfiguredInstance, getConfiguredInstance, getConfiguredInstances, getConfiguredInstances, getConfiguredInstances, getDouble, getInt, getList, getLong, getPassword, getShort, getString, hashCode, ignore, logUnused, nonInternalValues, originals, originals, originalsStrings, originalsWithPrefix, originalsWithPrefix, typeOf, unused, values, valuesWithPrefixAllOrNothing, valuesWithPrefixOverride

Methods inherited from class Object

getClass, notify, notifyAll, toString, wait, wait, wait

Field Details

REFRESH_INTERVAL_MS_CONFIG

public static final String REFRESH_INTERVAL_MS_CONFIG

See Also:

• Constant Field Values

DEFAULT_REFRESH_INTERVAL

public static final Long DEFAULT_REFRESH_INTERVAL

REFRESH_INTERVAL_MS_DOC

public static final String REFRESH_INTERVAL_MS_DOC

See Also:

• Constant Field Values

MAX_RETRY_ATTEMPTS_CONFIG

public static final String MAX_RETRY_ATTEMPTS_CONFIG

See Also:

• Constant Field Values

DEFAULT_MAX_RETRY_ATTEMPTS

public static final int DEFAULT_MAX_RETRY_ATTEMPTS

See Also:

• Constant Field Values

MAX_RETRY_ATTEMPTS_DOC

public static final String MAX_RETRY_ATTEMPTS_DOC

See Also:

• Constant Field Values

RETRY_INITIAL_DELAY_MS_CONFIG

public static final String RETRY_INITIAL_DELAY_MS_CONFIG

See Also:

• Constant Field Values

DEFAULT_RETRY_INITIAL_DELAY_MS

public static final long DEFAULT_RETRY_INITIAL_DELAY_MS

See Also:

• Constant Field Values

RETRY_INITIAL_DELAY_MS_DOC

public static final String RETRY_INITIAL_DELAY_MS_DOC

See Also:

• Constant Field Values

RETRY_MAX_DELAY_MS_CONFIG

public static final String RETRY_MAX_DELAY_MS_CONFIG

See Also:

• Constant Field Values

DEFAULT_RETRY_MAX_DELAY_MS

public static final long DEFAULT_RETRY_MAX_DELAY_MS

See Also:

• Constant Field Values

RETRY_MAX_DELAY_MS_DOC

public static final String RETRY_MAX_DELAY_MS_DOC

See Also:

• Constant Field Values

RETRY_BACKOFF_MULTIPLIER_CONFIG

public static final String RETRY_BACKOFF_MULTIPLIER_CONFIG

See Also:

• Constant Field Values

DEFAULT_RETRY_BACKOFF_MULTIPLIER

public static final double DEFAULT_RETRY_BACKOFF_MULTIPLIER

See Also:

• Constant Field Values

RETRY_BACKOFF_MULTIPLIER_DOC

public static final String RETRY_BACKOFF_MULTIPLIER_DOC

See Also:

• Constant Field Values

Constructor Details

PollingRemoteConfigurationConfig

public PollingRemoteConfigurationConfig(Map<?,?> originals,
 boolean doLog)

PollingRemoteConfigurationConfig

public PollingRemoteConfigurationConfig(org.apache.kafka.common.config.ConfigDef config,
 Map<?,?> originals,
 boolean doLog)

Constructor for child classes

Method Details

defineConfigs

public static org.apache.kafka.common.config.ConfigDef defineConfigs(org.apache.kafka.common.config.ConfigDef base)

getRefreshInterval

public Long getRefreshInterval()

getMaxRetryAttempts

public int getMaxRetryAttempts()

getRetryInitialDelayMs

public long getRetryInitialDelayMs()

getRetryMaxDelayMs

public long getRetryMaxDelayMs()

getRetryBackoffMultiplier

public double getRetryBackoffMultiplier()