public class EnvVarConfigProvider extends Object implements org.apache.kafka.common.config.provider.ConfigProvider
Constructor and Description |
---|
EnvVarConfigProvider()
Creates the configuration provider and gets the environment variables from the environment.
|
Modifier and Type | Method and Description |
---|---|
void |
close() |
void |
configure(Map<String,?> map) |
org.apache.kafka.common.config.ConfigData |
get(String path) |
org.apache.kafka.common.config.ConfigData |
get(String path,
Set<String> keys) |
public EnvVarConfigProvider()
public void configure(Map<String,?> map)
configure
in interface org.apache.kafka.common.Configurable
public org.apache.kafka.common.config.ConfigData get(String path)
get
in interface org.apache.kafka.common.config.provider.ConfigProvider
public org.apache.kafka.common.config.ConfigData get(String path, Set<String> keys)
get
in interface org.apache.kafka.common.config.provider.ConfigProvider
public void close()
close
in interface Closeable
close
in interface AutoCloseable
Copyright © 2021. All rights reserved.