Skip navigation links
A B C D E F G H I J L M N P R S T U V Z 

A

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
 
APPLICATION_JSON - Static variable in class io.confluent.telemetry.events.serde.Json
 
APPLICATION_JSON - Static variable in class io.confluent.telemetry.events.serde.Protobuf
 
APPLICATION_PROTOBUF - Static variable in class io.confluent.telemetry.events.serde.Protobuf
 

B

BinaryDeserializer<T> - Class in io.confluent.telemetry.events.serde
 
BinaryDeserializer(String, DataUnmarshaller<byte[], T, AttributesImpl>) - Constructor for class io.confluent.telemetry.events.serde.BinaryDeserializer
 
binaryDeserializer(Class<T>) - Static method in class io.confluent.telemetry.events.serde.Json
Get a Deserializer which can deserialize cloudevents using binary encoding.
binaryDeserializer(Parser<T>) - Static method in class io.confluent.telemetry.events.serde.Protobuf
Get a Deserializer which can deserialize cloudevents with Protobuf payload using binary encoding.
BinarySerializer<T> - Class in io.confluent.telemetry.events.serde
 
BinarySerializer(DataMarshaller<byte[], T, byte[]>) - Constructor for class io.confluent.telemetry.events.serde.BinarySerializer
 
binarySerializer() - Static method in class io.confluent.telemetry.events.serde.Json
Get a Serializer which can serialize cloudevents using binary encoding.
binarySerializer() - Static method in class io.confluent.telemetry.events.serde.Protobuf
Get a Serializer which can serialize cloudevents with Protobuf payload using binary encoding.
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
 
bufferingClient - Variable in class io.confluent.telemetry.events.exporter.http.HttpExporter
 
bufferingClient(BufferingAsyncTelemetryHttpClient<Data, Req, Resp>) - Method in class io.confluent.telemetry.events.exporter.http.HttpExporter
 
build() - Method in class io.confluent.telemetry.events.Event.Builder
 
builder - Variable in class io.confluent.telemetry.events.serde.Deserializer
 
builder - Variable in class io.confluent.telemetry.events.serde.Serializer
 

C

canEmitTelemetry - Variable in class io.confluent.telemetry.events.exporter.http.HttpExporter
 
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.EventLogger
 
close() - Method in class io.confluent.telemetry.events.exporter.http.HttpExporter
 
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_ENCODING_CONFIG - Static variable in class io.confluent.telemetry.events.EventLoggerConfig
 
CLOUD_EVENT_ENCODING_DOC - Static variable in class io.confluent.telemetry.events.EventLoggerConfig
 
CLOUD_EVENT_STRUCTURED_ENCODING - Static variable in class io.confluent.telemetry.events.EventLoggerConfig
 
configure(Map<String, ?>) - Method in class io.confluent.telemetry.events.EventLogger
 
configure(Map<String, ?>) - Method in class io.confluent.telemetry.events.exporter.http.HttpExporter
 
configure(Map<String, ?>) - Method in class io.confluent.telemetry.events.exporter.log.LogExporter
 
contentType(String) - Static method in class io.confluent.telemetry.events.serde.Protobuf
Get content type based on encoding
create(Map<String, ?>) - Method in interface io.confluent.telemetry.events.EventLoggerFactory
 
createJacksonMapper() - Static method in class io.confluent.telemetry.events.serde.Json
 

D

DEFAULT_CLOUD_EVENT_ENCODING_CONFIG - Static variable in class io.confluent.telemetry.events.EventLoggerConfig
 
DEFAULT_LOG_EVENT_EXPORTER_NAME_CONFIG - Static variable in class io.confluent.telemetry.events.exporter.log.LogExporterConfig
 
deserialize(Headers, byte[]) - Method in class io.confluent.telemetry.events.serde.Deserializer
 
deserialize(ConsumerRecord<?, byte[]>) - Method in class io.confluent.telemetry.events.serde.Deserializer
 
Deserializer<T> - Class in io.confluent.telemetry.events.serde
A class that deserializes a cloudevent from a Kafka message.
Deserializer() - Constructor for class io.confluent.telemetry.events.serde.Deserializer
 
deserializer(String, Class<T>, Parser<T>) - Static method in class io.confluent.telemetry.events.serde.Protobuf
 

E

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(Data) - Method in class io.confluent.telemetry.events.exporter.http.HttpExporter
 
emit(CloudEvent<AttributesImpl, T>) - Method in class io.confluent.telemetry.events.exporter.log.LogExporter
 
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
 
endpoint - Variable in class io.confluent.telemetry.events.exporter.http.HttpExporter
 
ensureValid(String, Object) - Method in class io.confluent.telemetry.events.exporter.http.HttpExporterConfig.URIValidator
 
Event - Class in io.confluent.telemetry.events
 
Event() - Constructor for class io.confluent.telemetry.events.Event
 
Event.Builder<T> - Class in io.confluent.telemetry.events
 
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
 
eventExporter() - Method in class io.confluent.telemetry.events.EventLogger
 
EventHttpExporter<T> - Class in io.confluent.telemetry.events.exporter.http
 
EventHttpExporter() - Constructor for class io.confluent.telemetry.events.exporter.http.EventHttpExporter
 
EventLogger<T> - 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
 
EventLoggerConfig - Class in io.confluent.telemetry.events
 
EventLoggerConfig(Map<String, ?>) - Constructor for class io.confluent.telemetry.events.EventLoggerConfig
 
EventLoggerFactory<T> - Interface in io.confluent.telemetry.events
 
Exporter<T> - Interface in io.confluent.telemetry.events.exporter
Exporters are responsible for delivering events to their destinations
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 in io.confluent.telemetry.events.exporter
 

F

forExecutables() - Method in class io.confluent.telemetry.events.NoopValidator
 
Format(RouteExtension) - Constructor for class io.confluent.telemetry.events.cloudevents.extensions.RouteExtension.Format
 

G

getApiSecretOrEmpty() - Method in class io.confluent.telemetry.events.exporter.http.HttpExporterConfig
 
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.
getConstraintsForClass(Class<?>) - Method in class io.confluent.telemetry.events.NoopValidator
 
getProxyPassword() - Method in class io.confluent.telemetry.events.exporter.http.HttpExporterConfig
 
getRoute() - Method in class io.confluent.telemetry.events.cloudevents.extensions.RouteExtension
 
getType() - Method in class io.confluent.telemetry.events.exporter.ExporterConfig
 

H

HttpExporter<Data,Req extends com.google.protobuf.MessageLite,Resp extends com.google.protobuf.MessageLite> - 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

IN_MEMORY_KEY - Static variable in class io.confluent.telemetry.events.cloudevents.extensions.RouteExtension.Format
 
INSTANCE - Static variable in class io.confluent.telemetry.events.NoopValidator
 
io.confluent.telemetry.events - package io.confluent.telemetry.events
 
io.confluent.telemetry.events.cloudevents.extensions - package io.confluent.telemetry.events.cloudevents.extensions
 
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.log - package io.confluent.telemetry.events.exporter.log
 
io.confluent.telemetry.events.serde - package io.confluent.telemetry.events.serde
 
isEnabled() - Method in class io.confluent.telemetry.events.exporter.ExporterConfig
 

J

Json - Class in io.confluent.telemetry.events.serde
Utility class to create the JSON serializers and deserializers.
Json() - Constructor for class io.confluent.telemetry.events.serde.Json
 

L

log(CloudEvent<AttributesImpl, T>) - 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
 
LogExporter<T extends com.google.protobuf.MessageLite> - 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
 
map(Map<String, Object>) - Static method in class io.confluent.telemetry.events.serde.BinaryDeserializer
 
memory() - Method in class io.confluent.telemetry.events.cloudevents.extensions.RouteExtension.Format
 

N

newBuilder() - Static method in class io.confluent.telemetry.events.Event
 
NoopValidator - Class in io.confluent.telemetry.events
A no-op implementation of the Validator interface.

P

parseType(Object) - Static method in class io.confluent.telemetry.events.exporter.ExporterConfig
 
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_PROXY - Static variable in class io.confluent.telemetry.events.exporter.http.HttpExporterConfig
 
producerRecord(CloudEvent<AttributesImpl, T>, String, Integer) - Method in class io.confluent.telemetry.events.serde.Serializer
 
producerRecord(CloudEvent<AttributesImpl, T>, String, Integer, String) - Method in class io.confluent.telemetry.events.serde.Serializer
 
Protobuf - Class in io.confluent.telemetry.events.serde
Utility class to create the Protobuf serializers and deserializers.
Protobuf() - Constructor for class io.confluent.telemetry.events.serde.Protobuf
 
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

ready(CloudEvent<AttributesImpl, T>) - 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
 
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.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.log.LogExporter
 
requestConverter - Variable in class io.confluent.telemetry.events.exporter.http.HttpExporter
 
responseDeserializer - Variable in class io.confluent.telemetry.events.exporter.http.HttpExporter
 
ROUTE_KEY - Static variable in class io.confluent.telemetry.events.cloudevents.extensions.RouteExtension.Format
 
RouteExtension - Class in io.confluent.telemetry.events.cloudevents.extensions
 
RouteExtension() - Constructor for class io.confluent.telemetry.events.cloudevents.extensions.RouteExtension
 
RouteExtension.Format - Class in io.confluent.telemetry.events.cloudevents.extensions
 
routeReady(T) - Method in interface io.confluent.telemetry.events.exporter.Exporter
Checks if a topic is ready.
routeReady(CloudEvent<AttributesImpl, T>) - Method in class io.confluent.telemetry.events.exporter.log.LogExporter
 

S

serialize(CloudEvent<AttributesImpl, T>) - Method in class io.confluent.telemetry.events.serde.Serializer
 
serialize(ZonedDateTime, JsonGenerator, SerializerProvider) - Method in class io.confluent.telemetry.events.serde.ZonedDateTimeMillisSerializer
 
Serializer<T> - Class in io.confluent.telemetry.events.serde
A class that serializes a cloudevent for Kafka transport.
Serializer() - Constructor for class io.confluent.telemetry.events.serde.Serializer
 
setData(T) - Method in class io.confluent.telemetry.events.Event.Builder
 
setDataContentType(String) - Method in class io.confluent.telemetry.events.Event.Builder
 
setDataSchema(URI) - Method in class io.confluent.telemetry.events.Event.Builder
 
setId(String) - Method in class io.confluent.telemetry.events.Event.Builder
 
setRoute(String) - Method in class io.confluent.telemetry.events.cloudevents.extensions.RouteExtension
 
setRoute(String) - Method in class io.confluent.telemetry.events.Event.Builder
 
setSource(String) - Method in class io.confluent.telemetry.events.Event.Builder
 
setSubject(String) - Method in class io.confluent.telemetry.events.Event.Builder
 
setTime(ZonedDateTime) - Method in class io.confluent.telemetry.events.Event.Builder
 
setType(String) - Method in class io.confluent.telemetry.events.Event.Builder
 
structuredBuilder(Function<byte[], CloudEventImpl<T>>) - Method in class io.confluent.telemetry.events.serde.StructuredDeserializer
The default Kafka UnMarshallers do not provide hooks to customize the unmarshalling of the cloudevent payload and custom extensions.
structuredBuilder(EnvelopeMarshaller<AttributesImpl, T, byte[]>) - Method in class io.confluent.telemetry.events.serde.StructuredSerializer
The default Kafka Marshallers do not provide hooks to customize the marshalling the cloudevent payload and custom extensions.
structuredDeserializer(Class<T>) - Static method in class io.confluent.telemetry.events.serde.Json
Get a Deserializer which can serialize cloudevents using structured encoding.
structuredDeserializer(Class<T>) - Static method in class io.confluent.telemetry.events.serde.Protobuf
Get a Deserializer which can serialize cloudevents with Protobuf payload using structured encoding.
StructuredDeserializer<T> - Class in io.confluent.telemetry.events.serde
A class that deserializes a cloudevent from a Kafka message.
StructuredDeserializer(Function<byte[], CloudEventImpl<T>>) - Constructor for class io.confluent.telemetry.events.serde.StructuredDeserializer
 
structuredSerializer() - Static method in class io.confluent.telemetry.events.serde.Json
Get a Serializer which can serialize cloudevents using structured encoding.
structuredSerializer() - Static method in class io.confluent.telemetry.events.serde.Protobuf
Get a Serializer which can serialize cloudevents with Protobuf payload using structured encoding.
StructuredSerializer<T> - Class in io.confluent.telemetry.events.serde
 
StructuredSerializer(EnvelopeMarshaller<AttributesImpl, T, byte[]>) - Constructor for class io.confluent.telemetry.events.serde.StructuredSerializer
 

T

toString(CloudEvent<AttributesImpl, T>) - Method in class io.confluent.telemetry.events.serde.Serializer
 
transport() - Method in class io.confluent.telemetry.events.cloudevents.extensions.RouteExtension.Format
 
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

uncheckedEncode(ObjectMapper, Object) - Static method in class io.confluent.telemetry.events.serde.Json
 
unmarshall(Map<String, String>) - Static method in class io.confluent.telemetry.events.cloudevents.extensions.RouteExtension
 
unwrap(Class<T>) - Method in class io.confluent.telemetry.events.NoopValidator
 
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
 
validate(T, Class<?>...) - Method in class io.confluent.telemetry.events.NoopValidator
 
validateProperty(T, String, Class<?>...) - Method in class io.confluent.telemetry.events.NoopValidator
 
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.log.LogExporter
 
validateValue(Class<T>, String, Object, Class<?>...) - Method in class io.confluent.telemetry.events.NoopValidator
 
valueOf(String) - Static method in enum io.confluent.telemetry.events.exporter.ExporterConfig.ExporterType
Returns the enum constant of this type with the specified name.
values() - Static method in enum io.confluent.telemetry.events.exporter.ExporterConfig.ExporterType
Returns an array containing the constants of this enum type, in the order they are declared.

Z

ZonedDateTimeMillisSerializer - Class in io.confluent.telemetry.events.serde
This Serializer always includes exactly 3 digits after the decimal point, capturing milliseconds.
ZonedDateTimeMillisSerializer() - Constructor for class io.confluent.telemetry.events.serde.ZonedDateTimeMillisSerializer
 
ZonedDateTimeMillisSerializer(Class<?>, boolean) - Constructor for class io.confluent.telemetry.events.serde.ZonedDateTimeMillisSerializer
 
A B C D E F G H I J L M N P R S T U V Z 
Skip navigation links