public class KubernetesConfigMapRemoteConfigurationSource extends PollingRemoteConfigurationSource
Constructor and Description |
---|
KubernetesConfigMapRemoteConfigurationSource(KubernetesConfigMapRemoteConfigurationConfig config,
Optional<String> physicalClusterId,
Consumer<io.confluent.telemetry.config.remote.v1.RemoteConfiguration> callback) |
Modifier and Type | Method and Description |
---|---|
static String |
parseDefaultEndpointFromEnv(KubernetesConfigMapRemoteConfigurationConfig config) |
static String |
parseEndpointFromEnv(KubernetesConfigMapRemoteConfigurationConfig config,
String configMapName) |
getConfig, setConfigurationChangeCallback, start, stop
public KubernetesConfigMapRemoteConfigurationSource(KubernetesConfigMapRemoteConfigurationConfig config, Optional<String> physicalClusterId, Consumer<io.confluent.telemetry.config.remote.v1.RemoteConfiguration> callback) throws CertificateException, NoSuchAlgorithmException, KeyStoreException, IOException, KeyManagementException
public static String parseEndpointFromEnv(KubernetesConfigMapRemoteConfigurationConfig config, String configMapName)
public static String parseDefaultEndpointFromEnv(KubernetesConfigMapRemoteConfigurationConfig config)