Class KubernetesConfigMapRemoteConfigurationSource<T>

java.lang.Object

io.confluent.security.audit.telemetry.exporter.config.remote.polling.PollingRemoteConfigurationSource<T>

io.confluent.security.audit.telemetry.exporter.config.remote.polling.kubernetes.KubernetesConfigMapRemoteConfigurationSource<T>

All Implemented Interfaces:

ICallbackResponse, 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>, ICallbackResponse

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

Field Summary

Fields

Modifier and Type	Field	Description
static final int	DEFAULT_RESOURCE_WATCHER_RETRY_COUNT
static final String	GROUP_NAME
static final int	HTTP_CONNECTION_TIMEOUT_MS
static final int	HTTP_READ_TIMEOUT_MS
static final String	METRIC_NAME

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)
org.apache.kafka.common.metrics.Sensor	getOrCreateWatcherSensor(String sensorName, Map<String,String> tags)
KubernetesResourceMetadata	getResourceMetadata()
void	onCallbackFailure(Exception e)
void	onCallbackSuccess()
void	recordWatcherMetric(String metricType, String path, int responseCode)
void	setMetrics(org.apache.kafka.common.metrics.Metrics metrics)

Methods inherited from class io.confluent.security.audit.telemetry.exporter.config.remote.polling.PollingRemoteConfigurationSource

getConfig, setConfigurationChangeCallback, start, stop

Methods inherited from class java.lang.Object

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

Field Details

DEFAULT_RESOURCE_WATCHER_RETRY_COUNT

public static final int DEFAULT_RESOURCE_WATCHER_RETRY_COUNT

See Also:

• Constant Field Values

HTTP_CONNECTION_TIMEOUT_MS

public static final int HTTP_CONNECTION_TIMEOUT_MS

See Also:

• Constant Field Values

HTTP_READ_TIMEOUT_MS

public static final int HTTP_READ_TIMEOUT_MS

See Also:

• Constant Field Values

METRIC_NAME

public static final String METRIC_NAME

See Also:

• Constant Field Values

GROUP_NAME

public static final String GROUP_NAME

See Also:

• Constant Field Values

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

setMetrics

public void setMetrics(org.apache.kafka.common.metrics.Metrics metrics)

recordWatcherMetric

public void recordWatcherMetric(String metricType,
 String path,
 int responseCode)

getOrCreateWatcherSensor

public org.apache.kafka.common.metrics.Sensor getOrCreateWatcherSensor(String sensorName,
 Map<String,String> tags)

createEndpointFromEnv

public static String createEndpointFromEnv(KubernetesConfigMapRemoteConfigurationConfig config,
 String configMapName)

createDefaultEndpointFromEnv

public static String createDefaultEndpointFromEnv(KubernetesConfigMapRemoteConfigurationConfig config)

getResourceMetadata

public KubernetesResourceMetadata getResourceMetadata()

onCallbackSuccess

public void onCallbackSuccess()

Specified by:

onCallbackSuccess in interface ICallbackResponse

onCallbackFailure

public void onCallbackFailure(Exception e)

Specified by:

onCallbackFailure in interface ICallbackResponse