Class KubernetesConfigMapRemoteConfigurationSource<T>

java.lang.Object

io.confluent.remote.config.poller.PollingRemoteConfigurationSource<T>

io.confluent.remote.config.poller.kubernetes.KubernetesConfigMapRemoteConfigurationSource<T>

All Implemented Interfaces:

RemoteConfigurationSource<T>, org.apache.kafka.common.security.oauthbearer.internals.secured.Retryable<T>

public class KubernetesConfigMapRemoteConfigurationSource<T>
extends PollingRemoteConfigurationSource<T>
implements org.apache.kafka.common.security.oauthbearer.internals.secured.Retryable<T>

This RemoteConfigurationSource will continuously poll the Kubernetes API for a ConfigMap containing the RemoteConfiguration object. It will do this by first querying for a ConfigMap with the same name as the cluster. If that ConfigMap does not exist, then it will use the one configured by CONFIG_MAP_NAME_CONFIG. We do this in break glass scenarios (incident remediation) where we need to remotely configure a single cluster

Constructor Summary

Constructors

Constructor	Description
KubernetesConfigMapRemoteConfigurationSource(KubernetesConfigMapRemoteConfigurationConfig config, Optional<String> physicalClusterId, Consumer<T> callback, Class<T> typeParameterClass)

Method Summary

Modifier and Type	Method	Description
T	call()
static String	createDefaultEndpointFromEnv(KubernetesConfigMapRemoteConfigurationConfig config)
static String	createEndpointFromEnv(KubernetesConfigMapRemoteConfigurationConfig config, String configMapName)
static com.fasterxml.jackson.databind.ObjectMapper	getObjectMapper()

Methods inherited from class io.confluent.remote.config.poller.PollingRemoteConfigurationSource

getConfig, setConfigurationChangeCallback, start, stop

Methods inherited from class java.lang.Object

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

Constructor Details

KubernetesConfigMapRemoteConfigurationSource

public KubernetesConfigMapRemoteConfigurationSource(KubernetesConfigMapRemoteConfigurationConfig config,
 Optional<String> physicalClusterId,
 Consumer<T> callback,
 Class<T> typeParameterClass)
                                             throws CertificateException,
NoSuchAlgorithmException,
KeyStoreException,
IOException,
KeyManagementException

Throws:

CertificateException

NoSuchAlgorithmException

KeyStoreException

IOException

KeyManagementException

Method Details

call

public T call()
       throws ExecutionException,
org.apache.kafka.common.security.oauthbearer.internals.secured.UnretryableException

Specified by:

call in interface org.apache.kafka.common.security.oauthbearer.internals.secured.Retryable<T>

Throws:

ExecutionException

org.apache.kafka.common.security.oauthbearer.internals.secured.UnretryableException

createEndpointFromEnv

public static String createEndpointFromEnv(KubernetesConfigMapRemoteConfigurationConfig config,
 String configMapName)

createDefaultEndpointFromEnv

public static String createDefaultEndpointFromEnv(KubernetesConfigMapRemoteConfigurationConfig config)

getObjectMapper

public static com.fasterxml.jackson.databind.ObjectMapper getObjectMapper()