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

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

Constructor Summary

Constructors

Constructor	Description
HttpClientConfig(String name, Map<?,?> originals, 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)
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 Details

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

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 Details

HttpClientConfig

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

Method Details

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)