io.confluent.telemetry.exporter.http

Class HttpClientConfig

java.lang.Object

org.apache.kafka.common.config.AbstractConfig

io.confluent.telemetry.exporter.ClientConfig

io.confluent.telemetry.exporter.http.HttpClientConfig

public class HttpClientConfig
extends ClientConfig

Nested Class Summary

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

ClientConfig.ClientConfigType

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_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_API
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.ClientConfig

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
HttpClientConfig(String name, Map<?,?> originals, boolean doLog)

Method Summary

Modifier and Type	Method and Description
<T,S> io.confluent.telemetry.client.TelemetryHttpClient.Builder<T,S>	configureClientDefaults(io.confluent.telemetry.client.TelemetryHttpClient.Builder<T,S> builder)
String	getClientMetricsPath()
io.confluent.telemetry.client.Credentials	getCredentials()
io.confluent.telemetry.client.ProxyConfig	getProxyConfig()

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

getName, getType, 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_API

public static final String PREFIX_API

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

PREFIX_BUFFER

public static final String PREFIX_BUFFER

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

PREFIX_CLIENT

public static final String PREFIX_CLIENT

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

PREFIX_PROXY

public static final String PREFIX_PROXY

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

HttpClientConfig

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

Method Detail

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)