Index

A B C D E F G H I K L M N P R S T U V W
All Classes and Interfaces|All Packages|Constant Field Values

A

acquire(HttpExporterConfig, Supplier<T>) - Method in class io.confluent.telemetry.events.exporter.http.HttpClientFactory

Acquire a shared resource for the given config.

API_KEY - Static variable in class io.confluent.telemetry.events.exporter.http.HttpExporterConfig

API_KEY_DOC - Static variable in class io.confluent.telemetry.events.exporter.http.HttpExporterConfig

API_SECRET - Static variable in class io.confluent.telemetry.events.exporter.http.HttpExporterConfig

API_SECRET_DOC - Static variable in class io.confluent.telemetry.events.exporter.http.HttpExporterConfig

AsyncKafkaExporter<T> - Class in io.confluent.telemetry.events.exporter.kafka.async

This KafkaExporter does not block the calling thread.

AsyncKafkaExporter.Builder<T> - Class in io.confluent.telemetry.events.exporter.kafka.async

B

BOOTSTRAP_SERVERS_CONFIG - Static variable in class io.confluent.telemetry.events.exporter.kafka.KafkaExporterConfig

BOOTSTRAP_SERVERS_DOC - Static variable in class io.confluent.telemetry.events.exporter.kafka.KafkaExporterConfig

buffer() - Method in class io.confluent.telemetry.events.exporter.kafka.async.AsyncKafkaExporter

BUFFER_MAX_BATCH_DURATION_MS - Static variable in class io.confluent.telemetry.events.exporter.http.HttpExporterConfig

BUFFER_MAX_BATCH_DURATION_MS_DOC - Static variable in class io.confluent.telemetry.events.exporter.http.HttpExporterConfig

BUFFER_MAX_BATCH_SIZE - Static variable in class io.confluent.telemetry.events.exporter.http.HttpExporterConfig

BUFFER_MAX_BATCH_SIZE_DOC - Static variable in class io.confluent.telemetry.events.exporter.http.HttpExporterConfig

BUFFER_MAX_INFLIGHT_SUBMISSIONS - Static variable in class io.confluent.telemetry.events.exporter.http.HttpExporterConfig

BUFFER_MAX_INFLIGHT_SUBMISSIONS_DOC - Static variable in class io.confluent.telemetry.events.exporter.http.HttpExporterConfig

BUFFER_MAX_PENDING_BATCHES - Static variable in class io.confluent.telemetry.events.exporter.http.HttpExporterConfig

BUFFER_MAX_PENDING_BATCHES_DOC - Static variable in class io.confluent.telemetry.events.exporter.http.HttpExporterConfig

build() - Method in class io.confluent.telemetry.events.exporter.kafka.async.AsyncKafkaExporter.Builder

build() - Method in class io.confluent.telemetry.events.exporter.kafka.EventAsyncKafkaExporter.Builder

Builder() - Constructor for class io.confluent.telemetry.events.exporter.kafka.EventAsyncKafkaExporter.Builder

C

canEmitTelemetry() - Method in class io.confluent.telemetry.events.exporter.http.HttpExporterConfig

CLIENT_BASE_URL - Static variable in class io.confluent.telemetry.events.exporter.http.HttpExporterConfig

CLIENT_BASE_URL_DOC - Static variable in class io.confluent.telemetry.events.exporter.http.HttpExporterConfig

CLIENT_COMPRESSION - Static variable in class io.confluent.telemetry.events.exporter.http.HttpExporterConfig

CLIENT_COMPRESSION_DOC - Static variable in class io.confluent.telemetry.events.exporter.http.HttpExporterConfig

CLIENT_CONNECT_TIMEOUT_MS - Static variable in class io.confluent.telemetry.events.exporter.http.HttpExporterConfig

CLIENT_CONNECT_TIMEOUT_MS_DOC - Static variable in class io.confluent.telemetry.events.exporter.http.HttpExporterConfig

CLIENT_MAX_ATTEMPTS - Static variable in class io.confluent.telemetry.events.exporter.http.HttpExporterConfig

CLIENT_MAX_ATTEMPTS_DOC - Static variable in class io.confluent.telemetry.events.exporter.http.HttpExporterConfig

CLIENT_REQUEST_TIMEOUT_MS - Static variable in class io.confluent.telemetry.events.exporter.http.HttpExporterConfig

CLIENT_REQUEST_TIMEOUT_MS_DOCS - Static variable in class io.confluent.telemetry.events.exporter.http.HttpExporterConfig

CLIENT_RETRY_DELAY_SEC - Static variable in class io.confluent.telemetry.events.exporter.http.HttpExporterConfig

CLIENT_RETRY_DELAY_SEC_DOC - Static variable in class io.confluent.telemetry.events.exporter.http.HttpExporterConfig

close() - Method in class io.confluent.telemetry.events.EventEmitterImpl

close() - Method in class io.confluent.telemetry.events.EventLogger

close() - Method in class io.confluent.telemetry.events.exporter.http.HttpExporter

close() - Method in class io.confluent.telemetry.events.exporter.kafka.async.AsyncKafkaExporter

close() - Method in class io.confluent.telemetry.events.exporter.kafka.KafkaExporter

close() - Method in class io.confluent.telemetry.events.exporter.kafka.RandomBrokerPartitionSubsetPartitioner

close() - Method in class io.confluent.telemetry.events.exporter.log.LogExporter

CLOUD_EVENT_BINARY_ENCODING - Static variable in class io.confluent.telemetry.events.EventLoggerConfig

CLOUD_EVENT_BINARY_ENCODING - Static variable in class io.confluent.telemetry.events.exporter.kafka.KafkaExporterConfig

CLOUD_EVENT_ENCODING_CONFIG - Static variable in class io.confluent.telemetry.events.EventLoggerConfig

CLOUD_EVENT_ENCODING_CONFIG - Static variable in class io.confluent.telemetry.events.exporter.kafka.KafkaExporterConfig

CLOUD_EVENT_ENCODING_DOC - Static variable in class io.confluent.telemetry.events.EventLoggerConfig

CLOUD_EVENT_ENCODING_DOC - Static variable in class io.confluent.telemetry.events.exporter.kafka.KafkaExporterConfig

CLOUD_EVENT_STRUCTURED_ENCODING - Static variable in class io.confluent.telemetry.events.EventLoggerConfig

CLOUD_EVENT_STRUCTURED_ENCODING - Static variable in class io.confluent.telemetry.events.exporter.kafka.KafkaExporterConfig

configure(Map<String, ?>) - Method in class io.confluent.telemetry.events.EventEmitterImpl

configure(Map<String, ?>) - Method in class io.confluent.telemetry.events.EventLogger

configure(Map<String, ?>) - Method in class io.confluent.telemetry.events.exporter.http.EventHttpExporter

configure(Map<String, ?>) - Method in class io.confluent.telemetry.events.exporter.http.HttpExporter

configure(Map<String, ?>) - Method in class io.confluent.telemetry.events.exporter.kafka.async.AsyncKafkaExporter

configure(Map<String, ?>) - Method in class io.confluent.telemetry.events.exporter.kafka.EventKafkaExporter

configure(Map<String, ?>) - Method in class io.confluent.telemetry.events.exporter.kafka.KafkaExporter

configure(Map<String, ?>) - Method in class io.confluent.telemetry.events.exporter.kafka.RandomBrokerPartitionSubsetPartitioner

configure(Map<String, ?>) - Method in class io.confluent.telemetry.events.exporter.log.LogExporter

CONNECTION_SSL_CONFIG_PREFIX - Static variable in class io.confluent.telemetry.events.exporter.http.HttpExporterConfig

create(Map<String, ?>) - Method in interface io.confluent.telemetry.events.EventLoggerFactory

D

DEFAULT_CLOUD_EVENT_ENCODING_CONFIG - Static variable in class io.confluent.telemetry.events.EventLoggerConfig

DEFAULT_CLOUD_EVENT_ENCODING_CONFIG - Static variable in class io.confluent.telemetry.events.exporter.kafka.KafkaExporterConfig

DEFAULT_EVENT_QUEUE_SIZE - Static variable in class io.confluent.telemetry.events.exporter.kafka.KafkaExporterConfig

DEFAULT_FILTERING_ENABLED - Static variable in class io.confluent.telemetry.events.exporter.http.HttpExporterConfig

DEFAULT_FILTERING_ENABLED - Static variable in class io.confluent.telemetry.events.exporter.kafka.KafkaExporterConfig

DEFAULT_LOG_EVENT_EXPORTER_NAME_CONFIG - Static variable in class io.confluent.telemetry.events.exporter.log.LogExporterConfig

DEFAULT_MIN_ISR - Static variable in class io.confluent.telemetry.events.exporter.kafka.KafkaExporterConfig

DEFAULT_PRODUCER_CLOSE_TIMEOUT - Static variable in class io.confluent.telemetry.events.exporter.kafka.KafkaExporterConfig

DEFAULT_ROUTES_ALLOWED - Static variable in class io.confluent.telemetry.events.exporter.http.HttpExporterConfig

DEFAULT_ROUTES_ALLOWED - Static variable in class io.confluent.telemetry.events.exporter.kafka.KafkaExporterConfig

DEFAULT_SUBSET_PARTITIONER_ENABLED - Static variable in class io.confluent.telemetry.events.exporter.kafka.KafkaExporterConfig

DEFAULT_SUBSET_PARTITIONER_PARTITION_PERCENTAGE - Static variable in class io.confluent.telemetry.events.exporter.kafka.RandomBrokerPartitionSubsetPartitioner

DEFAULT_TOPIC_CREATE - Static variable in class io.confluent.telemetry.events.exporter.kafka.KafkaExporterConfig

DEFAULT_TOPIC_MAX_MESSAGE_BYTES - Static variable in class io.confluent.telemetry.events.exporter.kafka.KafkaExporterConfig

DEFAULT_TOPIC_NAME - Static variable in class io.confluent.telemetry.events.exporter.kafka.KafkaExporterConfig

DEFAULT_TOPIC_PARTITIONS - Static variable in class io.confluent.telemetry.events.exporter.kafka.KafkaExporterConfig

DEFAULT_TOPIC_REPLICAS - Static variable in class io.confluent.telemetry.events.exporter.kafka.KafkaExporterConfig

DEFAULT_TOPIC_RETENTION_BYTES - Static variable in class io.confluent.telemetry.events.exporter.kafka.KafkaExporterConfig

DEFAULT_TOPIC_RETENTION_MS - Static variable in class io.confluent.telemetry.events.exporter.kafka.KafkaExporterConfig

DEFAULT_TOPIC_ROLL_MS - Static variable in class io.confluent.telemetry.events.exporter.kafka.KafkaExporterConfig

E

emit(Data) - Method in class io.confluent.telemetry.events.exporter.http.HttpExporter

emit(Event) - Method in class io.confluent.telemetry.events.EventEmitterImpl

emit(Event) - Method in class io.confluent.telemetry.events.exporter.log.LogExporter

emit(T) - Method in interface io.confluent.telemetry.events.exporter.Exporter

Filter and transform the events as appropriate and send to the specified destination.

emit(T) - Method in class io.confluent.telemetry.events.exporter.kafka.async.AsyncKafkaExporter

emit(T) - Method in class io.confluent.telemetry.events.exporter.kafka.KafkaExporter

ENABLED_CONFIG - Static variable in class io.confluent.telemetry.events.exporter.ExporterConfig

ENABLED_CONFIG_DEFAULT - Static variable in class io.confluent.telemetry.events.exporter.ExporterConfig

ENABLED_CONFIG_DOC - Static variable in class io.confluent.telemetry.events.exporter.ExporterConfig

ensureValid(String, Object) - Method in class io.confluent.telemetry.events.exporter.http.HttpExporterConfig.URIValidator

equals(Object) - Method in class io.confluent.telemetry.events.exporter.http.HttpExporterConfig

Equality and hash code based on all fields that determine HTTP client identity, including initial credentials and proxy settings.

EVENT_EXPORTER_CLASS_CONFIG - Static variable in class io.confluent.telemetry.events.EventLoggerConfig

EVENT_EXPORTER_CLASS_DOC - Static variable in class io.confluent.telemetry.events.EventLoggerConfig

EVENT_QUEUE_SIZE - Static variable in class io.confluent.telemetry.events.exporter.kafka.KafkaExporterConfig

EVENT_QUEUE_SIZE_DOC - Static variable in class io.confluent.telemetry.events.exporter.kafka.KafkaExporterConfig

EventAsyncKafkaExporter - Class in io.confluent.telemetry.events.exporter.kafka

EventAsyncKafkaExporter.Builder - Class in io.confluent.telemetry.events.exporter.kafka

EventEmitterConfig - Class in io.confluent.telemetry.events

EventEmitterConfig uses a hash map to save exporter configs, key is event type: events/metrics, value is a hash map, key is exporter name, value is a map of exporter configs.

EventEmitterConfig(Map<String, ?>) - Constructor for class io.confluent.telemetry.events.EventEmitterConfig

EventEmitterConfig.EventType - Enum Class in io.confluent.telemetry.events

EventEmitterImpl - Class in io.confluent.telemetry.events

EventEmitterImpl(Map<String, ?>) - Constructor for class io.confluent.telemetry.events.EventEmitterImpl

eventExporter() - Method in class io.confluent.telemetry.events.EventLogger

EventHttpExporter - Class in io.confluent.telemetry.events.exporter.http

EventHttpExporter() - Constructor for class io.confluent.telemetry.events.exporter.http.EventHttpExporter

EventKafkaExporter - Class in io.confluent.telemetry.events.exporter.kafka

EventKafkaExporter() - Constructor for class io.confluent.telemetry.events.exporter.kafka.EventKafkaExporter

EventLogger - Class in io.confluent.telemetry.events

This creates a logger that writes events to the configured exporter.

EventLogger() - Constructor for class io.confluent.telemetry.events.EventLogger

EventLogger(Function<EventLoggerConfig, Exporter<Event>>) - Constructor for class io.confluent.telemetry.events.EventLogger

EventLoggerConfig - Class in io.confluent.telemetry.events

EventLoggerConfig(Map<String, ?>) - Constructor for class io.confluent.telemetry.events.EventLoggerConfig

EventLoggerFactory - Interface in io.confluent.telemetry.events

EventRouteFilter - Class in io.confluent.telemetry.events.exporter.kafka

An event filter that filters based on the route extension.

EventRouteFilter(String...) - Constructor for class io.confluent.telemetry.events.exporter.kafka.EventRouteFilter

EventRouteFilter(Collection<String>) - Constructor for class io.confluent.telemetry.events.exporter.kafka.EventRouteFilter

events - Enum constant in enum class io.confluent.telemetry.events.EventEmitterConfig.EventType

EVENTS_ENABLED_CONFIG - Static variable in class io.confluent.telemetry.events.exporter.ExporterConfig

EVENTS_ENABLED_CONFIG_DEFAULT - Static variable in class io.confluent.telemetry.events.exporter.ExporterConfig

EVENTS_ENABLED_CONFIG_DOC - Static variable in class io.confluent.telemetry.events.exporter.ExporterConfig

EventUtils - Class in io.confluent.telemetry.events

EventUtils() - Constructor for class io.confluent.telemetry.events.EventUtils

Exporter<T> - Interface in io.confluent.telemetry.events.exporter

Exporters are responsible for delivering events to their destinations

EXPORTER_COMMON_CONFIG_PREFIXES - Static variable in class io.confluent.telemetry.events.exporter.ExporterConfig

EXPORTER_COMMON_CONFIGS - Static variable in class io.confluent.telemetry.events.exporter.ExporterConfig

ExporterConfig - Class in io.confluent.telemetry.events.exporter

ExporterConfig(Map<String, ?>) - Constructor for class io.confluent.telemetry.events.exporter.ExporterConfig

ExporterConfig(ConfigDef, Map<?, ?>) - Constructor for class io.confluent.telemetry.events.exporter.ExporterConfig

ExporterConfig(ConfigDef, Map<?, ?>, boolean) - Constructor for class io.confluent.telemetry.events.exporter.ExporterConfig

ExporterConfig.ExporterType - Enum Class in io.confluent.telemetry.events.exporter

Extensions - Interface in io.confluent.telemetry.events

F

FILTERING_ENABLED - Static variable in class io.confluent.telemetry.events.exporter.http.HttpExporterConfig

FILTERING_ENABLED - Static variable in class io.confluent.telemetry.events.exporter.kafka.KafkaExporterConfig

FILTERING_ENABLED_DOC - Static variable in class io.confluent.telemetry.events.exporter.http.HttpExporterConfig

FILTERING_ENABLED_DOC - Static variable in class io.confluent.telemetry.events.exporter.kafka.KafkaExporterConfig

format - Static variable in class io.confluent.telemetry.events.exporter.kafka.EventAsyncKafkaExporter

G

getAllowedRoutes() - Method in class io.confluent.telemetry.events.exporter.http.HttpExporterConfig

getAllowedRoutes() - Method in class io.confluent.telemetry.events.exporter.kafka.KafkaExporterConfig

getBufferingAsyncClientBuilder() - Method in class io.confluent.telemetry.events.exporter.http.HttpExporterConfig

getClientBuilder() - Method in class io.confluent.telemetry.events.exporter.http.HttpExporterConfig

getCompressionAlgorithm(String) - Method in class io.confluent.telemetry.events.exporter.http.HttpExporterConfig

Get the compression algorithm.

getCredentials() - Method in class io.confluent.telemetry.events.exporter.http.HttpExporterConfig

getEnabledExporterConfigs(EventEmitterConfig.EventType) - Method in class io.confluent.telemetry.events.EventEmitterConfig

Get exporter configs of a certain event type, only enabled exporters are returned

getEncoding() - Method in class io.confluent.telemetry.events.exporter.kafka.KafkaExporterConfig

getInstance() - Static method in class io.confluent.telemetry.events.exporter.http.HttpClientFactory

getNonInternalExporterConfigs(EventEmitterConfig.EventType) - Method in class io.confluent.telemetry.events.EventEmitterConfig

getProxyConfig() - Method in class io.confluent.telemetry.events.exporter.http.HttpExporterConfig

getSslContext() - Method in class io.confluent.telemetry.events.exporter.http.SslFactory

H

hashCode() - Method in class io.confluent.telemetry.events.exporter.http.HttpExporterConfig

http - Enum constant in enum class io.confluent.telemetry.events.exporter.ExporterConfig.ExporterType

HttpClientFactory - Class in io.confluent.telemetry.events.exporter.http

Manages shared HTTP client instances keyed by HttpExporterConfig.

HttpExporter<Data,Req,Resp> - Class in io.confluent.telemetry.events.exporter.http

HttpExporter() - Constructor for class io.confluent.telemetry.events.exporter.http.HttpExporter

HttpExporterConfig - Class in io.confluent.telemetry.events.exporter.http

Configuration for the HttpExporter.

HttpExporterConfig(Map<String, ?>) - Constructor for class io.confluent.telemetry.events.exporter.http.HttpExporterConfig

HttpExporterConfig.URIValidator - Class in io.confluent.telemetry.events.exporter.http

I

io.confluent.telemetry - package io.confluent.telemetry

io.confluent.telemetry.events - package io.confluent.telemetry.events

io.confluent.telemetry.events.exporter - package io.confluent.telemetry.events.exporter

io.confluent.telemetry.events.exporter.http - package io.confluent.telemetry.events.exporter.http

io.confluent.telemetry.events.exporter.kafka - package io.confluent.telemetry.events.exporter.kafka

io.confluent.telemetry.events.exporter.kafka.async - package io.confluent.telemetry.events.exporter.kafka.async

io.confluent.telemetry.events.exporter.log - package io.confluent.telemetry.events.exporter.log

isEventExporter(Map<String, Object>) - Method in class io.confluent.telemetry.events.EventEmitterConfig

isEventsExporterEnabled(Map<String, Object>) - Method in class io.confluent.telemetry.events.EventEmitterConfig

isFilteringEnabled() - Method in class io.confluent.telemetry.events.exporter.http.HttpExporterConfig

isFilteringEnabled() - Method in class io.confluent.telemetry.events.exporter.kafka.KafkaExporterConfig

isHttpExporter(Map<String, Object>) - Method in class io.confluent.telemetry.events.EventEmitterConfig

isInternalExporter(String) - Method in class io.confluent.telemetry.events.EventEmitterConfig

isKafkaExporter(Map<String, Object>) - Method in class io.confluent.telemetry.events.EventEmitterConfig

K

kafka - Enum constant in enum class io.confluent.telemetry.events.exporter.ExporterConfig.ExporterType

KafkaExporter<T> - Class in io.confluent.telemetry.events.exporter.kafka

KafkaExporter() - Constructor for class io.confluent.telemetry.events.exporter.kafka.KafkaExporter

KafkaExporter(Function<Properties, Producer<String, byte[]>>) - Constructor for class io.confluent.telemetry.events.exporter.kafka.KafkaExporter

KafkaExporterConfig - Class in io.confluent.telemetry.events.exporter.kafka

KafkaExporterConfig(Map<String, ?>) - Constructor for class io.confluent.telemetry.events.exporter.kafka.KafkaExporterConfig

L

log(Event) - Method in class io.confluent.telemetry.events.EventLogger

Log an event.

LOG_EVENT_EXPORTER_NAME_CONFIG - Static variable in class io.confluent.telemetry.events.exporter.log.LogExporterConfig

LOG_EVENT_EXPORTER_NAME_DOC - Static variable in class io.confluent.telemetry.events.exporter.log.LogExporterConfig

logAndGetFuture(Event) - Method in class io.confluent.telemetry.events.EventLogger

Log an event and return the future

LogExporter - Class in io.confluent.telemetry.events.exporter.log

The LogExporter sends events to the SLF4J-configured log file

LogExporter() - Constructor for class io.confluent.telemetry.events.exporter.log.LogExporter

LogExporterConfig - Class in io.confluent.telemetry.events.exporter.log

LogExporterConfig(Map<String, ?>) - Constructor for class io.confluent.telemetry.events.exporter.log.LogExporterConfig

M

main(String[]) - Static method in class io.confluent.telemetry.events.exporter.http.HttpExporterConfig

main(String[]) - Static method in class io.confluent.telemetry.events.exporter.kafka.KafkaExporterConfig

MAX_REQUEST_SIZE - Static variable in class io.confluent.telemetry.events.exporter.kafka.KafkaExporterConfig

metrics - Enum constant in enum class io.confluent.telemetry.events.EventEmitterConfig.EventType

METRICS_ENABLED_CONFIG - Static variable in class io.confluent.telemetry.events.exporter.ExporterConfig

METRICS_ENABLED_CONFIG_DEFAULT - Static variable in class io.confluent.telemetry.events.exporter.ExporterConfig

METRICS_ENABLED_CONFIG_DOC - Static variable in class io.confluent.telemetry.events.exporter.ExporterConfig

N

NamedConfigUtils - Class in io.confluent.telemetry

NamedConfigUtils() - Constructor for class io.confluent.telemetry.NamedConfigUtils

newBuilder() - Static method in class io.confluent.telemetry.events.exporter.kafka.async.AsyncKafkaExporter

newBuilder(Map<String, Object>) - Static method in class io.confluent.telemetry.events.exporter.kafka.EventAsyncKafkaExporter

P

parseNamedConfigs(Map<String, Map<String, Object>>, Map<String, Object>) - Static method in class io.confluent.telemetry.NamedConfigUtils

parseType(Object) - Static method in class io.confluent.telemetry.events.exporter.ExporterConfig

partition(String, Object, byte[], Object, byte[], Cluster) - Method in class io.confluent.telemetry.events.exporter.kafka.RandomBrokerPartitionSubsetPartitioner

Choose the partition for a record from partitions found on a limited number of brokers according to `subset.partitioner.partition.percentage`.

PARTITION_KEY - Static variable in interface io.confluent.telemetry.events.Extensions

PREFIX_BUFFER - Static variable in class io.confluent.telemetry.events.exporter.http.HttpExporterConfig

PREFIX_CLIENT - Static variable in class io.confluent.telemetry.events.exporter.http.HttpExporterConfig

PREFIX_EVENTS - Static variable in class io.confluent.telemetry.events.exporter.ExporterConfig

PREFIX_EXPORTER - Static variable in class io.confluent.telemetry.events.exporter.ExporterConfig

PREFIX_PRODUCER - Static variable in class io.confluent.telemetry.events.exporter.kafka.KafkaExporterConfig

PREFIX_PROXY - Static variable in class io.confluent.telemetry.events.exporter.http.HttpExporterConfig

PREFIX_TOPIC - Static variable in class io.confluent.telemetry.events.exporter.kafka.KafkaExporterConfig

producer() - Method in class io.confluent.telemetry.events.exporter.kafka.async.AsyncKafkaExporter

producer() - Method in class io.confluent.telemetry.events.exporter.kafka.KafkaExporter

PRODUCER_CONFIG_DEFAULTS - Static variable in class io.confluent.telemetry.events.exporter.kafka.KafkaExporterConfig

protoToBytes(Message, String) - Static method in class io.confluent.telemetry.events.EventUtils

PROXY_PASSWORD - Static variable in class io.confluent.telemetry.events.exporter.http.HttpExporterConfig

PROXY_PASSWORD_DOC - Static variable in class io.confluent.telemetry.events.exporter.http.HttpExporterConfig

PROXY_URL - Static variable in class io.confluent.telemetry.events.exporter.http.HttpExporterConfig

PROXY_URL_DOC - Static variable in class io.confluent.telemetry.events.exporter.http.HttpExporterConfig

PROXY_USERNAME - Static variable in class io.confluent.telemetry.events.exporter.http.HttpExporterConfig

PROXY_USERNAME_DOC - Static variable in class io.confluent.telemetry.events.exporter.http.HttpExporterConfig

R

RandomBrokerPartitionSubsetPartitioner - Class in io.confluent.telemetry.events.exporter.kafka

A partitioner that reduces the number of connections a producer needs to make by Specifying a subset percentage of total partitions to produce to Randomly connecting to brokers and taking all partitions on that broker until it has connected to the subset of partitions Randomly produce to the recorded partitions NOTE: This partitioner will not respect keys when determining the partition to be used. This is done so that keyed messages do not result in connections to every broker.

RandomBrokerPartitionSubsetPartitioner() - Constructor for class io.confluent.telemetry.events.exporter.kafka.RandomBrokerPartitionSubsetPartitioner

ready(Event) - Method in class io.confluent.telemetry.events.EventLogger

Check if the event exporter ready for sending events.

RECONFIGURABLE_CONFIGS - Static variable in class io.confluent.telemetry.events.exporter.http.HttpExporterConfig

RECONFIGURABLE_CONFIGS - Static variable in class io.confluent.telemetry.events.exporter.kafka.KafkaExporterConfig

reconfigurableConfigs() - Method in class io.confluent.telemetry.events.EventLogger

reconfigurableConfigs() - Method in class io.confluent.telemetry.events.exporter.http.HttpExporter

reconfigurableConfigs() - Method in class io.confluent.telemetry.events.exporter.kafka.async.AsyncKafkaExporter

reconfigurableConfigs() - Method in class io.confluent.telemetry.events.exporter.kafka.KafkaExporter

reconfigurableConfigs() - Method in class io.confluent.telemetry.events.exporter.log.LogExporter

RECONFIGURABLES - Static variable in class io.confluent.telemetry.events.exporter.ExporterConfig

reconfigure(Map<String, ?>) - Method in class io.confluent.telemetry.events.EventLogger

reconfigure(Map<String, ?>) - Method in class io.confluent.telemetry.events.exporter.http.HttpExporter

reconfigure(Map<String, ?>) - Method in class io.confluent.telemetry.events.exporter.kafka.async.AsyncKafkaExporter

reconfigure(Map<String, ?>) - Method in class io.confluent.telemetry.events.exporter.kafka.KafkaExporter

reconfigure(Map<String, ?>) - Method in class io.confluent.telemetry.events.exporter.log.LogExporter

release(HttpExporterConfig) - Method in class io.confluent.telemetry.events.exporter.http.HttpClientFactory

Release a reference to the shared resource for the given config.

ROUTE - Static variable in interface io.confluent.telemetry.events.Extensions

routeReady(Event) - Method in class io.confluent.telemetry.events.exporter.log.LogExporter

routeReady(T) - Method in interface io.confluent.telemetry.events.exporter.Exporter

Checks if a topic is ready.

ROUTES_ALLOWED - Static variable in class io.confluent.telemetry.events.exporter.http.HttpExporterConfig

ROUTES_ALLOWED - Static variable in class io.confluent.telemetry.events.exporter.kafka.KafkaExporterConfig

ROUTES_ALLOWED_DOC - Static variable in class io.confluent.telemetry.events.exporter.http.HttpExporterConfig

ROUTES_ALLOWED_DOC - Static variable in class io.confluent.telemetry.events.exporter.kafka.KafkaExporterConfig

S

setEventLabels(Map<String, String>) - Method in class io.confluent.telemetry.events.EventEmitterImpl

SingleTopicSupplier<T> - Class in io.confluent.telemetry.events.exporter.kafka.async

SingleTopicSupplier(NewTopic, Properties) - Constructor for class io.confluent.telemetry.events.exporter.kafka.async.SingleTopicSupplier

sslConfigs() - Method in class io.confluent.telemetry.events.exporter.http.HttpExporterConfig

SslFactory - Class in io.confluent.telemetry.events.exporter.http

SslFactory(Map<String, Object>) - Constructor for class io.confluent.telemetry.events.exporter.http.SslFactory

SUBSET_PARTITIONER_ENABLED - Static variable in class io.confluent.telemetry.events.exporter.kafka.KafkaExporterConfig

SUBSET_PARTITIONER_ENABLED_DOC - Static variable in class io.confluent.telemetry.events.exporter.kafka.KafkaExporterConfig

SUBSET_PARTITIONER_PARTITION_PERCENTAGE_CONFIG - Static variable in class io.confluent.telemetry.events.exporter.kafka.RandomBrokerPartitionSubsetPartitioner

SUBSET_PARTITIONER_RECALCULATION_BACKOFF_CONFIG - Static variable in class io.confluent.telemetry.events.exporter.kafka.RandomBrokerPartitionSubsetPartitioner

T

test - Enum constant in enum class io.confluent.telemetry.events.exporter.ExporterConfig.ExporterType

test(Event) - Method in class io.confluent.telemetry.events.exporter.kafka.EventRouteFilter

toCloudEvent(Event) - Static method in class io.confluent.telemetry.events.EventUtils

toJson(CloudEvent) - Static method in class io.confluent.telemetry.events.EventUtils

toJson(Event) - Static method in class io.confluent.telemetry.events.EventUtils

topic(T) - Method in class io.confluent.telemetry.events.exporter.kafka.async.SingleTopicSupplier

topic(T) - Method in interface io.confluent.telemetry.events.exporter.kafka.async.TopicSupplier

Get a topic for the record.

TOPIC_CREATE_CONFIG - Static variable in class io.confluent.telemetry.events.exporter.kafka.KafkaExporterConfig

TOPIC_CREATE_DOC - Static variable in class io.confluent.telemetry.events.exporter.kafka.KafkaExporterConfig

TOPIC_MAX_MESSAGE_BYTES_CONFIG - Static variable in class io.confluent.telemetry.events.exporter.kafka.KafkaExporterConfig

TOPIC_MAX_MESSAGE_BYTES_DOC - Static variable in class io.confluent.telemetry.events.exporter.kafka.KafkaExporterConfig

TOPIC_NAME_CONFIG - Static variable in class io.confluent.telemetry.events.exporter.kafka.KafkaExporterConfig

TOPIC_NAME_DOC - Static variable in class io.confluent.telemetry.events.exporter.kafka.KafkaExporterConfig

TOPIC_PARTITIONS_CONFIG - Static variable in class io.confluent.telemetry.events.exporter.kafka.KafkaExporterConfig

TOPIC_PARTITIONS_DOC - Static variable in class io.confluent.telemetry.events.exporter.kafka.KafkaExporterConfig

TOPIC_REPLICAS_CONFIG - Static variable in class io.confluent.telemetry.events.exporter.kafka.KafkaExporterConfig

TOPIC_REPLICAS_DOC - Static variable in class io.confluent.telemetry.events.exporter.kafka.KafkaExporterConfig

TOPIC_RETENTION_BYTES_CONFIG - Static variable in class io.confluent.telemetry.events.exporter.kafka.KafkaExporterConfig

TOPIC_RETENTION_BYTES_DOC - Static variable in class io.confluent.telemetry.events.exporter.kafka.KafkaExporterConfig

TOPIC_RETENTION_MS_CONFIG - Static variable in class io.confluent.telemetry.events.exporter.kafka.KafkaExporterConfig

TOPIC_RETENTION_MS_DOC - Static variable in class io.confluent.telemetry.events.exporter.kafka.KafkaExporterConfig

TOPIC_ROLL_MS_CONFIG - Static variable in class io.confluent.telemetry.events.exporter.kafka.KafkaExporterConfig

TOPIC_ROLL_MS_DOC - Static variable in class io.confluent.telemetry.events.exporter.kafka.KafkaExporterConfig

TopicSupplier<T> - Interface in io.confluent.telemetry.events.exporter.kafka.async

TYPE_CONFIG - Static variable in class io.confluent.telemetry.events.exporter.ExporterConfig

TYPE_CONFIG_DOC - Static variable in class io.confluent.telemetry.events.exporter.ExporterConfig

U

URIValidator() - Constructor for class io.confluent.telemetry.events.exporter.http.HttpExporterConfig.URIValidator

V

V1_EVENTS_ENDPOINT - Static variable in class io.confluent.telemetry.events.exporter.http.EventHttpExporter

validateReconfiguration(Map<String, ?>) - Method in class io.confluent.telemetry.events.EventLogger

validateReconfiguration(Map<String, ?>) - Method in class io.confluent.telemetry.events.exporter.http.HttpExporter

validateReconfiguration(Map<String, ?>) - Method in class io.confluent.telemetry.events.exporter.kafka.async.AsyncKafkaExporter

validateReconfiguration(Map<String, ?>) - Method in class io.confluent.telemetry.events.exporter.kafka.KafkaExporter

validateReconfiguration(Map<String, ?>) - Method in class io.confluent.telemetry.events.exporter.log.LogExporter

valueOf(String) - Static method in enum class io.confluent.telemetry.events.EventEmitterConfig.EventType

Returns the enum constant of this class with the specified name.

valueOf(String) - Static method in enum class io.confluent.telemetry.events.exporter.ExporterConfig.ExporterType

Returns the enum constant of this class with the specified name.

values() - Static method in enum class io.confluent.telemetry.events.EventEmitterConfig.EventType

Returns an array containing the constants of this enum class, in the order they are declared.

values() - Static method in enum class io.confluent.telemetry.events.exporter.ExporterConfig.ExporterType

Returns an array containing the constants of this enum class, in the order they are declared.

W

withBufferSize(int) - Method in class io.confluent.telemetry.events.exporter.kafka.async.AsyncKafkaExporter.Builder

withBufferSize(int) - Method in class io.confluent.telemetry.events.exporter.kafka.EventAsyncKafkaExporter.Builder

withDataSerializer(Function<Event, ProducerRecord<String, byte[]>>) - Method in class io.confluent.telemetry.events.exporter.kafka.EventAsyncKafkaExporter.Builder

withDataSerializer(Function<T, ProducerRecord<String, byte[]>>) - Method in class io.confluent.telemetry.events.exporter.kafka.async.AsyncKafkaExporter.Builder

withFilter(Predicate<Event>) - Method in class io.confluent.telemetry.events.exporter.kafka.EventAsyncKafkaExporter.Builder

withFilter(Predicate<T>) - Method in class io.confluent.telemetry.events.exporter.kafka.async.AsyncKafkaExporter.Builder

withProducerProperties(Properties) - Method in class io.confluent.telemetry.events.exporter.kafka.async.AsyncKafkaExporter.Builder

withProducerProperties(Properties) - Method in class io.confluent.telemetry.events.exporter.kafka.EventAsyncKafkaExporter.Builder

withTopicSupplier(TopicSupplier<Event>) - Method in class io.confluent.telemetry.events.exporter.kafka.EventAsyncKafkaExporter.Builder

withTopicSupplier(TopicSupplier<T>) - Method in class io.confluent.telemetry.events.exporter.kafka.async.AsyncKafkaExporter.Builder

A B C D E F G H I K L M N P R S T U V W
All Classes and Interfaces|All Packages|Constant Field Values