io.confluent.telemetry.exporter.http

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

Modifier and Type	Class and Description
static class	HttpExporterConfig.URIValidator

Nested classes/interfaces inherited from class io.confluent.telemetry.exporter.ExporterConfig

ExporterConfig.ExporterType

Field Summary

Fields

Modifier and Type	Field and Description
static String	API_KEY
static String	API_KEY_DOC
static String	API_SECRET
static String	API_SECRET_DOC
static String	BUFFER_MAX_BATCH_DURATION_MS
static String	BUFFER_MAX_BATCH_DURATION_MS_DOC
static String	BUFFER_MAX_BATCH_SIZE
static String	BUFFER_MAX_BATCH_SIZE_DOC
static String	BUFFER_MAX_INFLIGHT_SUBMISSIONS
static String	BUFFER_MAX_INFLIGHT_SUBMISSIONS_DOC
static String	BUFFER_MAX_PENDING_BATCHES
static String	BUFFER_MAX_PENDING_BATCHES_DOC
static String	CLIENT_BASE_URL
static String	CLIENT_BASE_URL_DOC
static String	CLIENT_COMPRESSION
static String	CLIENT_COMPRESSION_DOC
static String	CLIENT_CONNECT_TIMEOUT_MS
static String	CLIENT_CONNECT_TIMEOUT_MS_DOC
static String	CLIENT_CONTENT_TYPE
static String	CLIENT_CONTENT_TYPE_DOC
static String	CLIENT_MAX_ATTEMPTS
static String	CLIENT_MAX_ATTEMPTS_DOC
static String	CLIENT_METRICS_PATH
static String	CLIENT_METRICS_PATH_DEFAULT
static String	CLIENT_METRICS_PATH_DOC
static String	CLIENT_REQUEST_TIMEOUT_MS
static String	CLIENT_REQUEST_TIMEOUT_MS_DOCS
static String	CLIENT_RETRY_DELAY_SEC
static String	CLIENT_RETRY_DELAY_SEC_DOC
static String	PREFIX_BUFFER
static String	PREFIX_CLIENT
static String	PREFIX_PROXY
static String	PROXY_PASSWORD
static String	PROXY_PASSWORD_DOC
static String	PROXY_URL
static String	PROXY_URL_DOC
static String	PROXY_USERNAME
static String	PROXY_USERNAME_DOC
static Set<String>	RECONFIGURABLE_CONFIGS

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

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

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and Description
Boolean	canEmitMetrics()
<T,S> io.confluent.telemetry.client.TelemetryHttpClient.Builder<T,S>	configureClientDefaults(io.confluent.telemetry.client.TelemetryHttpClient.Builder<T,S> builder)
io.confluent.telemetry.client.BufferingAsyncTelemetryHttpClient.Builder<io.opentelemetry.proto.metrics.v1.Metric,io.opentelemetry.proto.collector.metrics.v1.ExportMetricsServiceRequest,io.opentelemetry.proto.collector.metrics.v1.ExportMetricsServiceResponse>	getBufferingAsyncClientBuilder()
io.confluent.telemetry.client.CompressionAlgorithm	getCompressionAlgorithm(String key) Get the compression algorithm.
io.confluent.telemetry.client.Credentials	getCredentials()
io.confluent.telemetry.client.ProxyConfig	getProxyConfig()
static void	main(String[] args)

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

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

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 Detail

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

public static final String CLIENT_CONTENT_TYPE

See Also:

Constant Field Values

CLIENT_CONTENT_TYPE_DOC

public static final String CLIENT_CONTENT_TYPE_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

RECONFIGURABLE_CONFIGS

public static final Set<String> RECONFIGURABLE_CONFIGS

Constructor Detail

HttpExporterConfig

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

HttpExporterConfig

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

Method Detail

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.

configureClientDefaults

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

getBufferingAsyncClientBuilder

public io.confluent.telemetry.client.BufferingAsyncTelemetryHttpClient.Builder<io.opentelemetry.proto.metrics.v1.Metric,io.opentelemetry.proto.collector.metrics.v1.ExportMetricsServiceRequest,io.opentelemetry.proto.collector.metrics.v1.ExportMetricsServiceResponse> getBufferingAsyncClientBuilder()

canEmitMetrics

public Boolean canEmitMetrics()