Class HttpExporterConfig

java.lang.Object

org.apache.kafka.common.config.AbstractConfig

io.confluent.telemetry.events.exporter.ExporterConfig

io.confluent.telemetry.events.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

Modifier and Type	Class	Description
static class	HttpExporterConfig.URIValidator

Nested classes/interfaces inherited from class io.confluent.telemetry.events.exporter.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_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	CONNECTION_SSL_CONFIG_PREFIX
static final boolean	DEFAULT_FILTERING_ENABLED
static final List<String>	DEFAULT_ROUTES_ALLOWED
static final String	FILTERING_ENABLED
static final String	FILTERING_ENABLED_DOC
static final String	PREFIX_BUFFER
static final String	PREFIX_CLIENT
static final String	PREFIX_PROXY
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
static final String	ROUTES_ALLOWED
static final String	ROUTES_ALLOWED_DOC

Fields inherited from class io.confluent.telemetry.events.exporter.ExporterConfig

ENABLED_CONFIG, ENABLED_CONFIG_DEFAULT, ENABLED_CONFIG_DOC, EVENTS_ENABLED_CONFIG, EVENTS_ENABLED_CONFIG_DEFAULT, EVENTS_ENABLED_CONFIG_DOC, EXPORTER_COMMON_CONFIG_PREFIXES, EXPORTER_COMMON_CONFIGS, METRICS_ENABLED_CONFIG, METRICS_ENABLED_CONFIG_DEFAULT, METRICS_ENABLED_CONFIG_DOC, PREFIX_EVENTS, PREFIX_EXPORTER, RECONFIGURABLES, TYPE_CONFIG, TYPE_CONFIG_DOC

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

AUTOMATIC_CONFIG_PROVIDERS_PROPERTY, CONFIG_PROVIDERS_CONFIG

Constructor Summary

Constructors

Constructor	Description
HttpExporterConfig(Map<String,?> originals)

Method Summary

Modifier and Type	Method	Description
Boolean	canEmitTelemetry()
Set<String>	getAllowedRoutes()
<Data, Req extends com.google.protobuf.MessageLite, Res extends com.google.protobuf.MessageLite> io.confluent.telemetry.client.BufferingAsyncTelemetryHttpClient.Builder<Data,Req,Res>	getBufferingAsyncClientBuilder()
<Req extends com.google.protobuf.MessageLite, Resp extends com.google.protobuf.MessageLite> io.confluent.telemetry.client.TelemetryHttpClient.Builder<Req,Resp>	getClientBuilder()
io.confluent.telemetry.client.CompressionAlgorithm	getCompressionAlgorithm(String key)	Get the compression algorithm.
io.confluent.telemetry.client.Credentials	getCredentials()
io.confluent.telemetry.client.ProxyConfig	getProxyConfig()
boolean	isFilteringEnabled()
static void	main(String[] args)
Map<String,Object>	sslConfigs()

Methods inherited from class io.confluent.telemetry.events.exporter.ExporterConfig

parseType

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

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

Methods inherited from class java.lang.Object

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

Field Details

PREFIX_BUFFER

public static final String PREFIX_BUFFER

See Also:

• Constant Field Values

PREFIX_CLIENT

public static final String PREFIX_CLIENT

See Also:

• Constant Field Values

PREFIX_PROXY

public static final String PREFIX_PROXY

See Also:

• Constant Field Values

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_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

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

FILTERING_ENABLED

public static final String FILTERING_ENABLED

See Also:

• Constant Field Values

FILTERING_ENABLED_DOC

public static final String FILTERING_ENABLED_DOC

See Also:

• Constant Field Values

DEFAULT_FILTERING_ENABLED

public static final boolean DEFAULT_FILTERING_ENABLED

See Also:

• Constant Field Values

ROUTES_ALLOWED

public static final String ROUTES_ALLOWED

See Also:

• Constant Field Values

ROUTES_ALLOWED_DOC

public static final String ROUTES_ALLOWED_DOC

See Also:

• Constant Field Values

DEFAULT_ROUTES_ALLOWED

public static final List<String> DEFAULT_ROUTES_ALLOWED

RECONFIGURABLE_CONFIGS

public static final Set<String> RECONFIGURABLE_CONFIGS

Constructor Details

HttpExporterConfig

public HttpExporterConfig(Map<String,?> originals)

Method Details

main

public static void main(String[] args)

getCredentials

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

getProxyConfig

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

getCompressionAlgorithm

public io.confluent.telemetry.client.CompressionAlgorithm getCompressionAlgorithm(String key)

Get the compression algorithm. If the algorithm is unknown, this returns null.

getClientBuilder

public <Req extends com.google.protobuf.MessageLite, Resp extends com.google.protobuf.MessageLite>
io.confluent.telemetry.client.TelemetryHttpClient.Builder<Req,Resp> getClientBuilder()

getBufferingAsyncClientBuilder

public <Data, Req extends com.google.protobuf.MessageLite, Res extends com.google.protobuf.MessageLite>
io.confluent.telemetry.client.BufferingAsyncTelemetryHttpClient.Builder<Data,Req,Res> getBufferingAsyncClientBuilder()

canEmitTelemetry

public Boolean canEmitTelemetry()

isFilteringEnabled

public boolean isFilteringEnabled()

getAllowedRoutes

public Set<String> getAllowedRoutes()

sslConfigs

public Map<String,Object> sslConfigs()