Class HttpExporterConfig

java.lang.Object

org.apache.kafka.common.config.AbstractConfig

io.confluent.telemetry.exporter.ExporterConfig

io.confluent.telemetry.exporter.http.HttpExporterConfig

public class HttpExporterConfig
extends ExporterConfig

Configuration for the HttpExporter. Note that we maintain the defaults in the `telemetry-client` library, so many of the defaults in this class are null.

Nested Class Summary

Nested classes/interfaces inherited from class ExporterConfig

ExporterConfig.ExporterType

Field Summary

Fields

Modifier and Type	Field	Description
static final String	API_KEY
static final String	API_KEY_DOC
static final String	API_SECRET
static final String	API_SECRET_DOC
static final String	BUFFER_MAX_BATCH_DURATION_MS
static final String	BUFFER_MAX_BATCH_DURATION_MS_DOC
static final String	BUFFER_MAX_BATCH_SIZE
static final String	BUFFER_MAX_BATCH_SIZE_DOC
static final String	BUFFER_MAX_INFLIGHT_SUBMISSIONS
static final String	BUFFER_MAX_INFLIGHT_SUBMISSIONS_DOC
static final String	BUFFER_MAX_PENDING_BATCHES
static final String	BUFFER_MAX_PENDING_BATCHES_DOC
static final String	CLIENT_BASE_URL
static final String	CLIENT_BASE_URL_DOC
static final String	CLIENT_COMPRESSION
static final String	CLIENT_COMPRESSION_DOC
static final String	CLIENT_CONNECT_TIMEOUT_MS
static final String	CLIENT_CONNECT_TIMEOUT_MS_DOC
static final String	CLIENT_MAX_ATTEMPTS
static final String	CLIENT_MAX_ATTEMPTS_DOC
static final String	CLIENT_METRICS_PATH
static final String	CLIENT_METRICS_PATH_DEFAULT
static final String	CLIENT_METRICS_PATH_DOC
static final String	CLIENT_PORT
static final int	CLIENT_PORT_DEFAULT
static final String	CLIENT_PORT_DOC
static final String	CLIENT_REQUEST_TIMEOUT_MS
static final String	CLIENT_REQUEST_TIMEOUT_MS_DOCS
static final String	CLIENT_RETRY_DELAY_SEC
static final String	CLIENT_RETRY_DELAY_SEC_DOC
static final String	CLIENT_USER_AGENT
static final String	CLIENT_USER_AGENT_DOC
static final String	CONNECTION_SSL_CONFIG_PREFIX
static final String	PROXY_PASSWORD
static final String	PROXY_PASSWORD_DOC
static final String	PROXY_URL
static final String	PROXY_URL_DOC
static final String	PROXY_USERNAME
static final String	PROXY_USERNAME_DOC
static final Set<String>	RECONFIGURABLE_CONFIGS

Fields inherited from class ExporterConfig

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

Fields inherited from class org.apache.kafka.common.config.AbstractConfig

AUTOMATIC_CONFIG_PROVIDERS_PROPERTY, CONFIG_PROVIDERS_CONFIG, CONFIG_PROVIDERS_DOC

Constructor Summary

Constructors

Constructor	Description
HttpExporterConfig(String name, Map<String,?> originals)
HttpExporterConfig(String name, Map<String,?> originals, boolean doLog)
HttpExporterConfig(String name, Map<String,?> originals, HttpClientConfig clientConfig, boolean doLog)

Method Summary

Modifier and Type	Method	Description
<T,S> io.confluent.telemetry.client.TelemetryHttpClient.Builder<T,S>	configureClientDefaults(io.confluent.telemetry.client.TelemetryHttpClient.Builder<T,S> builder)
boolean	equals(Object o)
HttpClientConfig	getClientConfig()
String	getClientMetricsPath()
String	getClientName()
io.confluent.telemetry.client.Credentials	getCredentials()
io.confluent.telemetry.client.ProxyConfig	getProxyConfig()
int	hashCode()
static void	main(String[] args)
Map<String,Object>	sslConfigs()

Methods inherited from class ExporterConfig

buildMetricsPredicate, getName, getType, isEnabled, isMetricsEnabled, isRemoteConfigurable, parseType, reconfigure

Methods inherited from class org.apache.kafka.common.config.AbstractConfig

documentationOf, getBoolean, getClass, getConfiguredInstance, getConfiguredInstance, getConfiguredInstances, getConfiguredInstances, getConfiguredInstances, getDouble, getInt, getList, getLong, getPassword, getShort, getString, ignore, logUnused, nonInternalValues, originals, originals, originalsStrings, originalsWithPrefix, originalsWithPrefix, typeOf, unused, values, valuesWithPrefixAllOrNothing, valuesWithPrefixOverride

Methods inherited from class Object

getClass, notify, notifyAll, toString, wait, wait, wait

Field Details

API_KEY

public static final String API_KEY

See Also:

• Constant Field Values

API_KEY_DOC

public static final String API_KEY_DOC

See Also:

• Constant Field Values

API_SECRET

public static final String API_SECRET

See Also:

• Constant Field Values

API_SECRET_DOC

public static final String API_SECRET_DOC

See Also:

• Constant Field Values

BUFFER_MAX_BATCH_DURATION_MS

public static final String BUFFER_MAX_BATCH_DURATION_MS

See Also:

• Constant Field Values

BUFFER_MAX_BATCH_DURATION_MS_DOC

public static final String BUFFER_MAX_BATCH_DURATION_MS_DOC

See Also:

• Constant Field Values

BUFFER_MAX_BATCH_SIZE

public static final String BUFFER_MAX_BATCH_SIZE

See Also:

• Constant Field Values

BUFFER_MAX_BATCH_SIZE_DOC

public static final String BUFFER_MAX_BATCH_SIZE_DOC

See Also:

• Constant Field Values

BUFFER_MAX_PENDING_BATCHES

public static final String BUFFER_MAX_PENDING_BATCHES

See Also:

• Constant Field Values

BUFFER_MAX_PENDING_BATCHES_DOC

public static final String BUFFER_MAX_PENDING_BATCHES_DOC

See Also:

• Constant Field Values

BUFFER_MAX_INFLIGHT_SUBMISSIONS

public static final String BUFFER_MAX_INFLIGHT_SUBMISSIONS

See Also:

• Constant Field Values

BUFFER_MAX_INFLIGHT_SUBMISSIONS_DOC

public static final String BUFFER_MAX_INFLIGHT_SUBMISSIONS_DOC

See Also:

• Constant Field Values

CLIENT_BASE_URL

public static final String CLIENT_BASE_URL

See Also:

• Constant Field Values

CLIENT_BASE_URL_DOC

public static final String CLIENT_BASE_URL_DOC

See Also:

• Constant Field Values

CLIENT_PORT

public static final String CLIENT_PORT

See Also:

• Constant Field Values

CLIENT_PORT_DOC

public static final String CLIENT_PORT_DOC

See Also:

• Constant Field Values

CLIENT_PORT_DEFAULT

public static final int CLIENT_PORT_DEFAULT

See Also:

• Constant Field Values

CLIENT_METRICS_PATH

public static final String CLIENT_METRICS_PATH

See Also:

• Constant Field Values

CLIENT_METRICS_PATH_DOC

public static final String CLIENT_METRICS_PATH_DOC

See Also:

• Constant Field Values

CLIENT_METRICS_PATH_DEFAULT

public static final String CLIENT_METRICS_PATH_DEFAULT

See Also:

• Constant Field Values

CLIENT_REQUEST_TIMEOUT_MS

public static final String CLIENT_REQUEST_TIMEOUT_MS

See Also:

• Constant Field Values

CLIENT_REQUEST_TIMEOUT_MS_DOCS

public static final String CLIENT_REQUEST_TIMEOUT_MS_DOCS

See Also:

• Constant Field Values

CLIENT_CONNECT_TIMEOUT_MS

public static final String CLIENT_CONNECT_TIMEOUT_MS

See Also:

• Constant Field Values

CLIENT_CONNECT_TIMEOUT_MS_DOC

public static final String CLIENT_CONNECT_TIMEOUT_MS_DOC

See Also:

• Constant Field Values

CLIENT_MAX_ATTEMPTS

public static final String CLIENT_MAX_ATTEMPTS

See Also:

• Constant Field Values

CLIENT_MAX_ATTEMPTS_DOC

public static final String CLIENT_MAX_ATTEMPTS_DOC

See Also:

• Constant Field Values

CLIENT_RETRY_DELAY_SEC

public static final String CLIENT_RETRY_DELAY_SEC

See Also:

• Constant Field Values

CLIENT_RETRY_DELAY_SEC_DOC

public static final String CLIENT_RETRY_DELAY_SEC_DOC

See Also:

• Constant Field Values

CLIENT_COMPRESSION

public static final String CLIENT_COMPRESSION

See Also:

• Constant Field Values

CLIENT_COMPRESSION_DOC

public static final String CLIENT_COMPRESSION_DOC

See Also:

• Constant Field Values

CLIENT_USER_AGENT

public static final String CLIENT_USER_AGENT

See Also:

• Constant Field Values

CLIENT_USER_AGENT_DOC

public static final String CLIENT_USER_AGENT_DOC

See Also:

• Constant Field Values

PROXY_URL

public static final String PROXY_URL

See Also:

• Constant Field Values

PROXY_URL_DOC

public static final String PROXY_URL_DOC

See Also:

• Constant Field Values

PROXY_USERNAME

public static final String PROXY_USERNAME

See Also:

• Constant Field Values

PROXY_USERNAME_DOC

public static final String PROXY_USERNAME_DOC

See Also:

• Constant Field Values

PROXY_PASSWORD

public static final String PROXY_PASSWORD

See Also:

• Constant Field Values

PROXY_PASSWORD_DOC

public static final String PROXY_PASSWORD_DOC

See Also:

• Constant Field Values

CONNECTION_SSL_CONFIG_PREFIX

public static final String CONNECTION_SSL_CONFIG_PREFIX

See Also:

• Constant Field Values

RECONFIGURABLE_CONFIGS

public static final Set<String> RECONFIGURABLE_CONFIGS

Constructor Details

HttpExporterConfig

public HttpExporterConfig(String name,
 Map<String,?> originals)

HttpExporterConfig

public HttpExporterConfig(String name,
 Map<String,?> originals,
 boolean doLog)

HttpExporterConfig

public HttpExporterConfig(String name,
 Map<String,?> originals,
 HttpClientConfig clientConfig,
 boolean doLog)

Method Details

main

public static void main(String[] args)

getClientConfig

public HttpClientConfig getClientConfig()

getClientName

public String getClientName()

getClientMetricsPath

public String getClientMetricsPath()

getCredentials

public io.confluent.telemetry.client.Credentials getCredentials()

getProxyConfig

public io.confluent.telemetry.client.ProxyConfig getProxyConfig()

configureClientDefaults

public <T,S>
io.confluent.telemetry.client.TelemetryHttpClient.Builder<T,S> configureClientDefaults(io.confluent.telemetry.client.TelemetryHttpClient.Builder<T,S> builder)

equals

public boolean equals(Object o)

Overrides:

equals in class org.apache.kafka.common.config.AbstractConfig

hashCode

public int hashCode()

Overrides:

hashCode in class org.apache.kafka.common.config.AbstractConfig

sslConfigs

public Map<String,Object> sslConfigs()