Package io.streamthoughts.azkarra.runtime.interceptors

Class KafkaBrokerReadyInterceptorConfig

java.lang.Object

io.streamthoughts.azkarra.runtime.interceptors.KafkaBrokerReadyInterceptorConfig

public class KafkaBrokerReadyInterceptorConfig
extends Object

Field Summary

Fields

Modifier and Type	Field	Description
static String	KAFKA_READY_INTERCEPTOR_ENABLE_CONFIG	kafka.ready.interceptor.enable
static String	KAFKA_READY_INTERCEPTOR_MIN_AVAILABLE_BROKERS_CONFIG	kafka.ready.interceptor.min.available.brokers
static int	KAFKA_READY_INTERCEPTOR_MIN_AVAILABLE_BROKERS_DEFAULT
static String	KAFKA_READY_INTERCEPTOR_RETRY_BACKOFF_MS_CONFIG	kafka.ready.interceptor.connect.backoff.ms
static long	KAFKA_READY_INTERCEPTOR_RETRY_BACKOFF_MS_DEFAULT
static String	KAFKA_READY_INTERCEPTOR_TIMEOUT_MS_CONFIG	kafka.ready.interceptor.timeout.ms
static long	KAFKA_READY_INTERCEPTOR_TIMEOUT_MS_DEFAULT

Constructor Summary

Constructors

Constructor	Description
KafkaBrokerReadyInterceptorConfig(Conf originals)	Creates a new KafkaBrokerReadyInterceptorConfig instance.

Method Summary

Modifier and Type	Method	Description
int	getMinAvailableBrokers()
long	getRetryBackoffMs()
long	getTimeoutMs()

Methods inherited from class java.lang.Object

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

Field Detail

KAFKA_READY_INTERCEPTOR_ENABLE_CONFIG

public static final String KAFKA_READY_INTERCEPTOR_ENABLE_CONFIG

kafka.ready.interceptor.enable

See Also:

Constant Field Values

KAFKA_READY_INTERCEPTOR_TIMEOUT_MS_CONFIG

public static final String KAFKA_READY_INTERCEPTOR_TIMEOUT_MS_CONFIG

kafka.ready.interceptor.timeout.ms

See Also:

Constant Field Values

KAFKA_READY_INTERCEPTOR_TIMEOUT_MS_DEFAULT

public static final long KAFKA_READY_INTERCEPTOR_TIMEOUT_MS_DEFAULT

See Also:

Constant Field Values

KAFKA_READY_INTERCEPTOR_RETRY_BACKOFF_MS_CONFIG

public static final String KAFKA_READY_INTERCEPTOR_RETRY_BACKOFF_MS_CONFIG

kafka.ready.interceptor.connect.backoff.ms

See Also:

Constant Field Values

KAFKA_READY_INTERCEPTOR_RETRY_BACKOFF_MS_DEFAULT

public static final long KAFKA_READY_INTERCEPTOR_RETRY_BACKOFF_MS_DEFAULT

See Also:

Constant Field Values

KAFKA_READY_INTERCEPTOR_MIN_AVAILABLE_BROKERS_CONFIG

public static final String KAFKA_READY_INTERCEPTOR_MIN_AVAILABLE_BROKERS_CONFIG

kafka.ready.interceptor.min.available.brokers

See Also:

Constant Field Values

KAFKA_READY_INTERCEPTOR_MIN_AVAILABLE_BROKERS_DEFAULT

public static final int KAFKA_READY_INTERCEPTOR_MIN_AVAILABLE_BROKERS_DEFAULT

See Also:

Constant Field Values

Constructor Detail

KafkaBrokerReadyInterceptorConfig

public KafkaBrokerReadyInterceptorConfig(Conf originals)

Creates a new KafkaBrokerReadyInterceptorConfig instance.

Parameters:

originals - the Conf.

Method Detail

getTimeoutMs

public long getTimeoutMs()

getRetryBackoffMs

public long getRetryBackoffMs()

getMinAvailableBrokers

public int getMinAvailableBrokers()