public class KubernetesConfigMapRemoteConfigurationSource<T> extends PollingRemoteConfigurationSource<T> implements org.apache.kafka.common.security.oauthbearer.internals.secured.Retryable<T>
| Constructor and Description |
|---|
KubernetesConfigMapRemoteConfigurationSource(KubernetesConfigMapRemoteConfigurationConfig config,
Optional<String> physicalClusterId,
Consumer<T> callback,
Class<T> typeParameterClass) |
| Modifier and Type | Method and Description |
|---|---|
T |
call() |
static String |
createDefaultEndpointFromEnv(KubernetesConfigMapRemoteConfigurationConfig config) |
static String |
createEndpointFromEnv(KubernetesConfigMapRemoteConfigurationConfig config,
String configMapName) |
getConfig, setConfigurationChangeCallback, start, stoppublic KubernetesConfigMapRemoteConfigurationSource(KubernetesConfigMapRemoteConfigurationConfig config, Optional<String> physicalClusterId, Consumer<T> callback, Class<T> typeParameterClass) throws CertificateException, NoSuchAlgorithmException, KeyStoreException, IOException, KeyManagementException
public T call() throws ExecutionException, org.apache.kafka.common.security.oauthbearer.internals.secured.UnretryableException
call in interface org.apache.kafka.common.security.oauthbearer.internals.secured.Retryable<T>ExecutionExceptionorg.apache.kafka.common.security.oauthbearer.internals.secured.UnretryableExceptionpublic static String createEndpointFromEnv(KubernetesConfigMapRemoteConfigurationConfig config, String configMapName)
public static String createDefaultEndpointFromEnv(KubernetesConfigMapRemoteConfigurationConfig config)