C D E G H I K M N P R S V

C

call() - Method in class io.confluent.remote.config.poller.kubernetes.KubernetesConfigMapRemoteConfigurationSource

clone() - Method in interface io.confluent.remote.config.poller.RemoteConfiguration

CONFIG_MAP_NAME_CONFIG - Static variable in class io.confluent.remote.config.poller.kubernetes.KubernetesConfigMapRemoteConfigurationConfig

CONFIG_MAP_NAME_DOC - Static variable in class io.confluent.remote.config.poller.kubernetes.KubernetesConfigMapRemoteConfigurationConfig

ConfigSet - Class in io.confluent.remote.config.poller.kubernetes

This class is used to parse the ConfigMap returned from the Kubernetes API.

ConnectLogEventsConfig - Class in io.confluent.remote.config.poller

ConnectLogEventsConfig(String, String) - Constructor for class io.confluent.remote.config.poller.ConnectLogEventsConfig

createDefaultEndpointFromEnv(KubernetesConfigMapRemoteConfigurationConfig) - Static method in class io.confluent.remote.config.poller.kubernetes.KubernetesConfigMapRemoteConfigurationSource

createEndpointFromEnv(KubernetesConfigMapRemoteConfigurationConfig, String) - Static method in class io.confluent.remote.config.poller.kubernetes.KubernetesConfigMapRemoteConfigurationSource

D

DEFAULT_ENABLED - Static variable in class io.confluent.remote.config.poller.RemoteConfigConfiguration

DEFAULT_MAX_RETRY_BACKOFF_MS - Static variable in class io.confluent.remote.config.poller.kubernetes.KubernetesConfigMapRemoteConfigurationConfig

DEFAULT_REFRESH_INTERVAL - Static variable in class io.confluent.remote.config.poller.PollingRemoteConfigConfiguration

DEFAULT_RETRY_BACKOFF_MS - Static variable in class io.confluent.remote.config.poller.kubernetes.KubernetesConfigMapRemoteConfigurationConfig

defineConfigs(ConfigDef) - Static method in class io.confluent.remote.config.poller.PollingRemoteConfigConfiguration

E

ENABLED_CONFIG - Static variable in class io.confluent.remote.config.poller.RemoteConfigConfiguration

ENABLED_CONFIG_DOC - Static variable in class io.confluent.remote.config.poller.RemoteConfigConfiguration

equals(Object) - Method in class io.confluent.remote.config.poller.ConnectLogEventsConfig

equals(Object) - Method in class io.confluent.remote.config.poller.kubernetes.ConfigSet

G

getBootstrapServers() - Method in class io.confluent.remote.config.poller.ConnectLogEventsConfig

getCompatibleConfigVersion(String, Class<T>) - Method in class io.confluent.remote.config.poller.kubernetes.ConfigSet

The ConfigMap will hold 1 remote configuration objects for each major API schema version.

getConfig() - Method in class io.confluent.remote.config.poller.PollingRemoteConfigurationSource

This method is used to get the current configuration before starting the polling.

getConfig() - Method in interface io.confluent.remote.config.poller.RemoteConfigurationSource

Returns the latest received configuration from this source.

getData() - Method in class io.confluent.remote.config.poller.kubernetes.V1ConfigMap

getJaasConfig() - Method in class io.confluent.remote.config.poller.ConnectLogEventsConfig

getMaxRetryBackoffMs() - Method in class io.confluent.remote.config.poller.kubernetes.KubernetesConfigMapRemoteConfigurationConfig

getMetadata() - Method in class io.confluent.remote.config.poller.kubernetes.V1ConfigMap

getName() - Method in class io.confluent.remote.config.poller.kubernetes.V1ObjectMeta

getNamespace() - Method in class io.confluent.remote.config.poller.kubernetes.V1ObjectMeta

getObjectMapper() - Static method in class io.confluent.remote.config.poller.kubernetes.KubernetesConfigMapRemoteConfigurationSource

getRefreshIntervalMs() - Method in class io.confluent.remote.config.poller.PollingRemoteConfigConfiguration

getRegion() - Method in enum io.confluent.remote.config.poller.Region

getResourceVersion() - Method in class io.confluent.remote.config.poller.kubernetes.V1ObjectMeta

getRetryBackoffMs() - Method in class io.confluent.remote.config.poller.kubernetes.KubernetesConfigMapRemoteConfigurationConfig

getSchemaVersion() - Method in class io.confluent.remote.config.poller.kubernetes.KubernetesConfigMapRemoteConfigurationConfig

H

hashCode() - Method in class io.confluent.remote.config.poller.ConnectLogEventsConfig

hashCode() - Method in class io.confluent.remote.config.poller.kubernetes.ConfigSet

I

io.confluent.remote.config.poller - package io.confluent.remote.config.poller

io.confluent.remote.config.poller.kubernetes - package io.confluent.remote.config.poller.kubernetes

isEnabled() - Method in class io.confluent.remote.config.poller.RemoteConfigConfiguration

K

KubernetesConfigMapRemoteConfigurationConfig - Class in io.confluent.remote.config.poller.kubernetes

KubernetesConfigMapRemoteConfigurationConfig(Map<?, ?>, boolean) - Constructor for class io.confluent.remote.config.poller.kubernetes.KubernetesConfigMapRemoteConfigurationConfig

KubernetesConfigMapRemoteConfigurationSource<T> - Class in io.confluent.remote.config.poller.kubernetes

This RemoteConfigurationSource will continuously poll the Kubernetes API for a ConfigMap containing the RemoteConfiguration object.

KubernetesConfigMapRemoteConfigurationSource(KubernetesConfigMapRemoteConfigurationConfig, Optional<String>, Consumer<T>, Class<T>) - Constructor for class io.confluent.remote.config.poller.kubernetes.KubernetesConfigMapRemoteConfigurationSource

M

MAX_RETRY_BACKOFF_MS - Static variable in class io.confluent.remote.config.poller.kubernetes.KubernetesConfigMapRemoteConfigurationConfig

MAX_RETRY_BACKOFF_MS_DOC - Static variable in class io.confluent.remote.config.poller.kubernetes.KubernetesConfigMapRemoteConfigurationConfig

N

NAMESPACE_CONFIG - Static variable in class io.confluent.remote.config.poller.kubernetes.KubernetesConfigMapRemoteConfigurationConfig

NAMESPACE_DOC - Static variable in class io.confluent.remote.config.poller.kubernetes.KubernetesConfigMapRemoteConfigurationConfig

P

parseConfigYaml(String) - Static method in class io.confluent.remote.config.poller.kubernetes.ConfigSet

We need to provide this convoluted way of parsing configs returned from the ConfigMap because k8s only allows us to specify ConfigMaps of Map<String, String>; so we're unable to interpret the yaml directly.

PollingRemoteConfigConfiguration - Class in io.confluent.remote.config.poller

PollingRemoteConfigConfiguration(ConfigDef, Map<?, ?>, boolean) - Constructor for class io.confluent.remote.config.poller.PollingRemoteConfigConfiguration

Constructor for child classes

PollingRemoteConfigurationSource<T> - Class in io.confluent.remote.config.poller

This PollingRemoteConfigurationSource class provides a generic polling implementation for remote configuration sources.

PollingRemoteConfigurationSource(long, Consumer<T>, Class<T>) - Constructor for class io.confluent.remote.config.poller.PollingRemoteConfigurationSource

R

REFRESH_INTERVAL_SEC_CONFIG - Static variable in class io.confluent.remote.config.poller.PollingRemoteConfigConfiguration

REFRESH_INTERVAL_SEC_DOC - Static variable in class io.confluent.remote.config.poller.PollingRemoteConfigConfiguration

Region - Enum in io.confluent.remote.config.poller

RemoteConfigConfiguration - Class in io.confluent.remote.config.poller

RemoteConfigConfiguration(ConfigDef, Map<?, ?>, boolean) - Constructor for class io.confluent.remote.config.poller.RemoteConfigConfiguration

RemoteConfiguration - Interface in io.confluent.remote.config.poller

RemoteConfigurationSource<T> - Interface in io.confluent.remote.config.poller

RETRY_BACKOFF_MS - Static variable in class io.confluent.remote.config.poller.kubernetes.KubernetesConfigMapRemoteConfigurationConfig

RETRY_BACKOFF_MS_DOC - Static variable in class io.confluent.remote.config.poller.kubernetes.KubernetesConfigMapRemoteConfigurationConfig

S

SCHEMA_VERSION_CONFIG - Static variable in class io.confluent.remote.config.poller.kubernetes.KubernetesConfigMapRemoteConfigurationConfig

SCHEMA_VERSION_DOC - Static variable in class io.confluent.remote.config.poller.kubernetes.KubernetesConfigMapRemoteConfigurationConfig

setConfigurationChangeCallback(Consumer<T>) - Method in class io.confluent.remote.config.poller.PollingRemoteConfigurationSource

Only one callback can be registered.

setConfigurationChangeCallback(Consumer<T>) - Method in interface io.confluent.remote.config.poller.RemoteConfigurationSource

Registers a callback to be called when the remote configuration has changed

start() - Method in class io.confluent.remote.config.poller.PollingRemoteConfigurationSource

start() - Method in interface io.confluent.remote.config.poller.RemoteConfigurationSource

stop() - Method in class io.confluent.remote.config.poller.PollingRemoteConfigurationSource

stop() - Method in interface io.confluent.remote.config.poller.RemoteConfigurationSource

V

V1ConfigMap - Class in io.confluent.remote.config.poller.kubernetes

Custom object for Kubernetes V1ConfigMap We define the fields we need here instead of pulling all K8s APIs to keep the size of the jar small

V1ConfigMap(Map<String, String>, V1ObjectMeta) - Constructor for class io.confluent.remote.config.poller.kubernetes.V1ConfigMap

V1ObjectMeta - Class in io.confluent.remote.config.poller.kubernetes

Custom object for Kubernetes configmap metadata name: The name of the kubernetes resource namespace: The namespace of the kubernetes resource resourceVersion: The version of the kubernetes resource

V1ObjectMeta(String, String, String) - Constructor for class io.confluent.remote.config.poller.kubernetes.V1ObjectMeta

valueOf(String) - Static method in enum io.confluent.remote.config.poller.Region

Returns the enum constant of this type with the specified name.

values() - Static method in enum io.confluent.remote.config.poller.Region

Returns an array containing the constants of this enum type, in the order they are declared.

C D E G H I K M N P R S V