public class KafkaExporterConfig extends ExporterConfig
ExporterConfig.ExporterType
CLIENT_NAME_CONFIG, CLIENT_NAME_CONFIG_DEFAULT, CLIENT_NAME_CONFIG_DOC, ENABLED_CONFIG, ENABLED_CONFIG_DOC, EVENTS_ENABLED_CONFIG, EVENTS_ENABLED_CONFIG_DEFAULT, EVENTS_ENABLED_CONFIG_DOC, METRICS_ENABLED_CONFIG, METRICS_ENABLED_CONFIG_DEFAULT, METRICS_ENABLED_CONFIG_DOC, METRICS_INCLUDE_CONFIG, METRICS_INCLUDE_CONFIG_DOC, NAMED_CLIENT_CONFIGURED_DOC_WARNING, RECONFIGURABLES, REMOTE_CONFIGURABLE_CONFIG, REMOTE_CONFIGURABLE_CONFIG_DEFAULT, REMOTE_CONFIGURABLE_CONFIG_DOC, TYPE_CONFIG, TYPE_CONFIG_DOC
Constructor and Description |
---|
KafkaExporterConfig(String name,
Map<String,?> originals) |
KafkaExporterConfig(String name,
Map<String,?> originals,
boolean doLog) |
KafkaExporterConfig(String name,
Map<String,?> originals,
ProducerClientConfig clientConfig,
boolean doLog) |
Modifier and Type | Method and Description |
---|---|
ProducerClientConfig |
getClientConfig() |
String |
getClientName() |
boolean |
hasNamedClient() |
boolean |
hasNativeClientConfigs() |
static void |
main(String[] args) |
buildMetricsPredicate, getName, getType, isEnabled, isMetricsEnabled, isRemoteConfigurable, parseType, reconfigure
documentationOf, equals, getBoolean, getClass, getConfiguredInstance, getConfiguredInstance, getConfiguredInstances, getConfiguredInstances, getConfiguredInstances, getDouble, getInt, getList, getLong, getPassword, getShort, getString, hashCode, ignore, logUnused, nonInternalValues, originals, originals, originalsStrings, originalsWithPrefix, originalsWithPrefix, typeOf, unused, values, valuesWithPrefixAllOrNothing, valuesWithPrefixOverride
public static final String PREFIX_PRODUCER
public static final String BOOTSTRAP_SERVERS_CONFIG
public static final String BOOTSTRAP_SERVERS_DOC
public static final String BOOTSTRAP_SERVERS_DEFAULT
public static final String PREFIX_TOPIC
public static final String TOPIC_NAME_CONFIG
public static final String TOPIC_NAME_DOC
public static final String DEFAULT_TOPIC_NAME
public static final String TOPIC_CREATE_CONFIG
public static final String TOPIC_CREATE_DOC
public static final boolean DEFAULT_TOPIC_CREATE
public static final String TOPIC_PARTITIONS_CONFIG
public static final String TOPIC_PARTITIONS_DOC
public static final int DEFAULT_TOPIC_PARTITIONS
public static final String TOPIC_REPLICAS_CONFIG
public static final String TOPIC_REPLICAS_DOC
public static final int DEFAULT_TOPIC_REPLICAS
public static final String TOPIC_RETENTION_MS_CONFIG
public static final String TOPIC_RETENTION_MS_DOC
public static final long DEFAULT_TOPIC_RETENTION_MS
public static final String TOPIC_RETENTION_BYTES_CONFIG
public static final String TOPIC_RETENTION_BYTES_DOC
public static final long DEFAULT_TOPIC_RETENTION_BYTES
public static final String TOPIC_ROLL_MS_CONFIG
public static final String TOPIC_ROLL_MS_DOC
public static final long DEFAULT_TOPIC_ROLL_MS
public static final String TOPIC_MAX_MESSAGE_BYTES_CONFIG
public static final String TOPIC_MAX_MESSAGE_BYTES_DOC
public static final int DEFAULT_TOPIC_MAX_MESSAGE_BYTES
public KafkaExporterConfig(String name, Map<String,?> originals, ProducerClientConfig clientConfig, boolean doLog)
name
- name of the exporteroriginals
- original configsclientConfig
- client config is using a configured named (static) clientdoLog
- whether the configurations should be loggedpublic static void main(String[] args)
public String getClientName()
public boolean hasNamedClient()
public boolean hasNativeClientConfigs()
public ProducerClientConfig getClientConfig()