Index (ce-logs 8.0.3-ce API)

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

A

AUTHORITY_NAME - Static variable in class io.confluent.logevents.connect.LogEventsConfig

B

build() - Method in class io.confluent.logevents.connect.ConnectLogEntry.Builder
build() - Method in class io.confluent.logevents.connect.Context.Builder
build() - Method in class io.confluent.logevents.connect.Summary.Builder
build() - Method in class io.confluent.logevents.connect.Summary.ConnectorErrorSummary.Builder
buildPartial() - Method in class io.confluent.logevents.connect.ConnectLogEntry.Builder
buildPartial() - Method in class io.confluent.logevents.connect.Context.Builder
buildPartial() - Method in class io.confluent.logevents.connect.Summary.Builder
buildPartial() - Method in class io.confluent.logevents.connect.Summary.ConnectorErrorSummary.Builder

C

clear() - Method in class io.confluent.logevents.connect.ConnectLogEntry.Builder
clear() - Method in class io.confluent.logevents.connect.Context.Builder
clear() - Method in class io.confluent.logevents.connect.Summary.Builder
clear() - Method in class io.confluent.logevents.connect.Summary.ConnectorErrorSummary.Builder
clearConnectorErrorSummary() - Method in class io.confluent.logevents.connect.Summary.Builder: .logs.Summary.ConnectorErrorSummary connector_error_summary = 1;
clearConnectorId() - Method in class io.confluent.logevents.connect.Context.Builder: string connector_id = 1;
clearContext() - Method in class io.confluent.logevents.connect.ConnectLogEntry.Builder: .logs.Context context = 2;
clearLevel() - Method in class io.confluent.logevents.connect.ConnectLogEntry.Builder: string level = 1;
clearMessage() - Method in class io.confluent.logevents.connect.Summary.ConnectorErrorSummary.Builder: string message = 1;
clearMessageSummary() - Method in class io.confluent.logevents.connect.Summary.Builder
clearRootCause() - Method in class io.confluent.logevents.connect.Summary.ConnectorErrorSummary.Builder: string root_cause = 2;
clearSummary() - Method in class io.confluent.logevents.connect.ConnectLogEntry.Builder: .logs.Summary summary = 3;
configureRemoteConfigurationSource(Map<String, ?>) - Method in class io.confluent.logevents.connect.LogEventsKafkaEmitter
CONFLUENT_EVENT_LOGGER_KAFKA_EXPORTER_PREFIX - Static variable in class io.confluent.logevents.connect.LogEventsConfig
CONFLUENT_EVENT_LOGGER_PREFIX - Static variable in class io.confluent.logevents.connect.LogEventsConfig
CONFLUENT_LOG_PREFIX_REMOTE_CONFIG - Static variable in class io.confluent.logevents.connect.LogEventsConfig
CONFLUENT_LOG_REMOTE_CONFIG_CLOUD - Static variable in class io.confluent.logevents.connect.LogEventsConfig
CONFLUENT_PREFIX - Static variable in class io.confluent.logevents.connect.LogEventsConfig
ConnectLogEntry - Class in io.confluent.logevents.connect: Connect log events payload
ConnectLogEntry.Builder - Class in io.confluent.logevents.connect: Connect log events payload
ConnectLogEntryOrBuilder - Interface in io.confluent.logevents.connect
ConnectLogProto - Class in io.confluent.logevents.connect
CONNECTOR_ERROR_SUMMARY - Enum constant in enum class io.confluent.logevents.connect.Summary.MessageSummaryCase
CONNECTOR_ERROR_SUMMARY_FIELD_NUMBER - Static variable in class io.confluent.logevents.connect.Summary
CONNECTOR_ID_FIELD_NUMBER - Static variable in class io.confluent.logevents.connect.Context
connectorFailedEvent(Supplier<LogEventsEmitter>, Map<String, String>, String, Throwable, Optional<LogEventState>) - Static method in class io.confluent.logevents.connect.LogEvents: Constructs ConnectLogEntry for a Connector failure event, and forwards the entry to LogEventsEmitter to emit it in the form of CloudEvent to the destination topic.
connectorTaskFailedEvent(Supplier<LogEventsEmitter>, Map<String, String>, String, String, Throwable, Optional<LogEventState>) - Static method in class io.confluent.logevents.connect.LogEvents: Constructs ConnectLogEntry for a Connector Task failure event, and forwards the entry to LogEventsEmitter to emit it in the form of CloudEvent to the destination topic.
Context - Class in io.confluent.logevents.connect: Context captures the details of the context in which the current Log Event is being captured.
CONTEXT_FIELD_NUMBER - Static variable in class io.confluent.logevents.connect.ConnectLogEntry
Context.Builder - Class in io.confluent.logevents.connect: Context captures the details of the context in which the current Log Event is being captured.
ContextOrBuilder - Interface in io.confluent.logevents.connect
createLogEventState(Function<Map.Entry<String, LogEventState>, LogEventState>, String, long) - Static method in class io.confluent.logevents.connect.LogEvents

D

DEFAULT_EVENT_EXPORTER_CLASS_CONFIG - Static variable in class io.confluent.logevents.connect.LogEventsConfig
DEFAULT_LOGGER_BOOTSTRAP_SERVERS - Static variable in class io.confluent.logevents.connect.LogEventsConfig
DEFAULT_LOGGER_CLIENT_ID - Static variable in class io.confluent.logevents.connect.LogEventsConfig
DEFAULT_LOGGER_ENABLE - Static variable in class io.confluent.logevents.connect.LogEventsConfig
DEFAULT_TOPIC - Static variable in class io.confluent.logevents.connect.LogEventsConfig
DEFAULT_TOPIC_CREATE_CONFIG - Static variable in class io.confluent.logevents.connect.LogEventsConfig

E

emit(ConnectLogEntry, String, String, String) - Method in interface io.confluent.logevents.connect.LogEventsEmitter: Construct a connect Log Event and emit it to the preconfigured destination.
emit(ConnectLogEntry, String, String, String) - Method in class io.confluent.logevents.connect.LogEventsKafkaEmitter
equals(Object) - Method in class io.confluent.logevents.connect.ConnectLogEntry
equals(Object) - Method in class io.confluent.logevents.connect.Context
equals(Object) - Method in class io.confluent.logevents.connect.LogEventState
equals(Object) - Method in class io.confluent.logevents.connect.RemoteConnectLogsConfiguration
equals(Object) - Method in class io.confluent.logevents.connect.Summary.ConnectorErrorSummary
equals(Object) - Method in class io.confluent.logevents.connect.Summary

F

forNumber(int) - Static method in enum class io.confluent.logevents.connect.Summary.MessageSummaryCase

G

getActiveRegion() - Method in class io.confluent.logevents.connect.RemoteConnectLogsConfiguration
getConnectLogEventsProducerConfig(Region) - Method in class io.confluent.logevents.connect.RemoteConnectLogsConfiguration
getConnectorErrorSummary() - Method in class io.confluent.logevents.connect.Summary.Builder: .logs.Summary.ConnectorErrorSummary connector_error_summary = 1;
getConnectorErrorSummary() - Method in class io.confluent.logevents.connect.Summary: .logs.Summary.ConnectorErrorSummary connector_error_summary = 1;
getConnectorErrorSummary() - Method in interface io.confluent.logevents.connect.SummaryOrBuilder: .logs.Summary.ConnectorErrorSummary connector_error_summary = 1;
getConnectorErrorSummaryBuilder() - Method in class io.confluent.logevents.connect.Summary.Builder: .logs.Summary.ConnectorErrorSummary connector_error_summary = 1;
getConnectorErrorSummaryOrBuilder() - Method in class io.confluent.logevents.connect.Summary.Builder: .logs.Summary.ConnectorErrorSummary connector_error_summary = 1;
getConnectorErrorSummaryOrBuilder() - Method in class io.confluent.logevents.connect.Summary: .logs.Summary.ConnectorErrorSummary connector_error_summary = 1;
getConnectorErrorSummaryOrBuilder() - Method in interface io.confluent.logevents.connect.SummaryOrBuilder: .logs.Summary.ConnectorErrorSummary connector_error_summary = 1;
getConnectorId() - Method in class io.confluent.logevents.connect.Context.Builder: string connector_id = 1;
getConnectorId() - Method in class io.confluent.logevents.connect.Context: string connector_id = 1;
getConnectorId() - Method in interface io.confluent.logevents.connect.ContextOrBuilder: string connector_id = 1;
getConnectorIdBytes() - Method in class io.confluent.logevents.connect.Context.Builder: string connector_id = 1;
getConnectorIdBytes() - Method in class io.confluent.logevents.connect.Context: string connector_id = 1;
getConnectorIdBytes() - Method in interface io.confluent.logevents.connect.ContextOrBuilder: string connector_id = 1;
getContext() - Method in class io.confluent.logevents.connect.ConnectLogEntry.Builder: .logs.Context context = 2;
getContext() - Method in class io.confluent.logevents.connect.ConnectLogEntry: .logs.Context context = 2;
getContext() - Method in interface io.confluent.logevents.connect.ConnectLogEntryOrBuilder: .logs.Context context = 2;
getContextBuilder() - Method in class io.confluent.logevents.connect.ConnectLogEntry.Builder: .logs.Context context = 2;
getContextOrBuilder() - Method in class io.confluent.logevents.connect.ConnectLogEntry.Builder: .logs.Context context = 2;
getContextOrBuilder() - Method in class io.confluent.logevents.connect.ConnectLogEntry: .logs.Context context = 2;
getContextOrBuilder() - Method in interface io.confluent.logevents.connect.ConnectLogEntryOrBuilder: .logs.Context context = 2;
getDefaultInstance() - Static method in class io.confluent.logevents.connect.ConnectLogEntry
getDefaultInstance() - Static method in class io.confluent.logevents.connect.Context
getDefaultInstance() - Static method in class io.confluent.logevents.connect.Summary.ConnectorErrorSummary
getDefaultInstance() - Static method in class io.confluent.logevents.connect.Summary
getDefaultInstanceForType() - Method in class io.confluent.logevents.connect.ConnectLogEntry.Builder
getDefaultInstanceForType() - Method in class io.confluent.logevents.connect.ConnectLogEntry
getDefaultInstanceForType() - Method in class io.confluent.logevents.connect.Context.Builder
getDefaultInstanceForType() - Method in class io.confluent.logevents.connect.Context
getDefaultInstanceForType() - Method in class io.confluent.logevents.connect.Summary.Builder
getDefaultInstanceForType() - Method in class io.confluent.logevents.connect.Summary.ConnectorErrorSummary.Builder
getDefaultInstanceForType() - Method in class io.confluent.logevents.connect.Summary.ConnectorErrorSummary
getDefaultInstanceForType() - Method in class io.confluent.logevents.connect.Summary
getDescriptor() - Static method in class io.confluent.logevents.connect.ConnectLogEntry.Builder
getDescriptor() - Static method in class io.confluent.logevents.connect.ConnectLogEntry
getDescriptor() - Static method in class io.confluent.logevents.connect.ConnectLogProto
getDescriptor() - Static method in class io.confluent.logevents.connect.Context.Builder
getDescriptor() - Static method in class io.confluent.logevents.connect.Context
getDescriptor() - Static method in class io.confluent.logevents.connect.Summary.Builder
getDescriptor() - Static method in class io.confluent.logevents.connect.Summary.ConnectorErrorSummary.Builder
getDescriptor() - Static method in class io.confluent.logevents.connect.Summary.ConnectorErrorSummary
getDescriptor() - Static method in class io.confluent.logevents.connect.Summary
getDescriptorForType() - Method in class io.confluent.logevents.connect.ConnectLogEntry.Builder
getDescriptorForType() - Method in class io.confluent.logevents.connect.Context.Builder
getDescriptorForType() - Method in class io.confluent.logevents.connect.Summary.Builder
getDescriptorForType() - Method in class io.confluent.logevents.connect.Summary.ConnectorErrorSummary.Builder
getLevel() - Method in class io.confluent.logevents.connect.ConnectLogEntry.Builder: string level = 1;
getLevel() - Method in class io.confluent.logevents.connect.ConnectLogEntry: string level = 1;
getLevel() - Method in interface io.confluent.logevents.connect.ConnectLogEntryOrBuilder: string level = 1;
getLevelBytes() - Method in class io.confluent.logevents.connect.ConnectLogEntry.Builder: string level = 1;
getLevelBytes() - Method in class io.confluent.logevents.connect.ConnectLogEntry: string level = 1;
getLevelBytes() - Method in interface io.confluent.logevents.connect.ConnectLogEntryOrBuilder: string level = 1;
getMessage() - Method in class io.confluent.logevents.connect.Summary.ConnectorErrorSummary.Builder: string message = 1;
getMessage() - Method in class io.confluent.logevents.connect.Summary.ConnectorErrorSummary: string message = 1;
getMessage() - Method in interface io.confluent.logevents.connect.Summary.ConnectorErrorSummaryOrBuilder: string message = 1;
getMessageBytes() - Method in class io.confluent.logevents.connect.Summary.ConnectorErrorSummary.Builder: string message = 1;
getMessageBytes() - Method in class io.confluent.logevents.connect.Summary.ConnectorErrorSummary: string message = 1;
getMessageBytes() - Method in interface io.confluent.logevents.connect.Summary.ConnectorErrorSummaryOrBuilder: string message = 1;
getMessageSummaryCase() - Method in class io.confluent.logevents.connect.Summary.Builder
getMessageSummaryCase() - Method in class io.confluent.logevents.connect.Summary
getMessageSummaryCase() - Method in interface io.confluent.logevents.connect.SummaryOrBuilder
getNumber() - Method in enum class io.confluent.logevents.connect.Summary.MessageSummaryCase
getParserForType() - Method in class io.confluent.logevents.connect.ConnectLogEntry
getParserForType() - Method in class io.confluent.logevents.connect.Context
getParserForType() - Method in class io.confluent.logevents.connect.Summary.ConnectorErrorSummary
getParserForType() - Method in class io.confluent.logevents.connect.Summary
getRemoteConfiguration() - Method in class io.confluent.logevents.connect.LogEventsKafkaEmitter
getRootCause() - Method in class io.confluent.logevents.connect.Summary.ConnectorErrorSummary.Builder: string root_cause = 2;
getRootCause() - Method in class io.confluent.logevents.connect.Summary.ConnectorErrorSummary: string root_cause = 2;
getRootCause() - Method in interface io.confluent.logevents.connect.Summary.ConnectorErrorSummaryOrBuilder: string root_cause = 2;
getRootCauseBytes() - Method in class io.confluent.logevents.connect.Summary.ConnectorErrorSummary.Builder: string root_cause = 2;
getRootCauseBytes() - Method in class io.confluent.logevents.connect.Summary.ConnectorErrorSummary: string root_cause = 2;
getRootCauseBytes() - Method in interface io.confluent.logevents.connect.Summary.ConnectorErrorSummaryOrBuilder: string root_cause = 2;
getSchemaVersion() - Static method in class io.confluent.logevents.connect.RemoteConnectLogsConfiguration
getSerializedSize() - Method in class io.confluent.logevents.connect.ConnectLogEntry
getSerializedSize() - Method in class io.confluent.logevents.connect.Context
getSerializedSize() - Method in class io.confluent.logevents.connect.Summary.ConnectorErrorSummary
getSerializedSize() - Method in class io.confluent.logevents.connect.Summary
getSummary() - Method in class io.confluent.logevents.connect.ConnectLogEntry.Builder: .logs.Summary summary = 3;
getSummary() - Method in class io.confluent.logevents.connect.ConnectLogEntry: .logs.Summary summary = 3;
getSummary() - Method in interface io.confluent.logevents.connect.ConnectLogEntryOrBuilder: .logs.Summary summary = 3;
getSummaryBuilder() - Method in class io.confluent.logevents.connect.ConnectLogEntry.Builder: .logs.Summary summary = 3;
getSummaryOrBuilder() - Method in class io.confluent.logevents.connect.ConnectLogEntry.Builder: .logs.Summary summary = 3;
getSummaryOrBuilder() - Method in class io.confluent.logevents.connect.ConnectLogEntry: .logs.Summary summary = 3;
getSummaryOrBuilder() - Method in interface io.confluent.logevents.connect.ConnectLogEntryOrBuilder: .logs.Summary summary = 3;

H

hasConnectorErrorSummary() - Method in class io.confluent.logevents.connect.Summary.Builder: .logs.Summary.ConnectorErrorSummary connector_error_summary = 1;
hasConnectorErrorSummary() - Method in class io.confluent.logevents.connect.Summary: .logs.Summary.ConnectorErrorSummary connector_error_summary = 1;
hasConnectorErrorSummary() - Method in interface io.confluent.logevents.connect.SummaryOrBuilder: .logs.Summary.ConnectorErrorSummary connector_error_summary = 1;
hasContext() - Method in class io.confluent.logevents.connect.ConnectLogEntry.Builder: .logs.Context context = 2;
hasContext() - Method in class io.confluent.logevents.connect.ConnectLogEntry: .logs.Context context = 2;
hasContext() - Method in interface io.confluent.logevents.connect.ConnectLogEntryOrBuilder: .logs.Context context = 2;
hashCode() - Method in class io.confluent.logevents.connect.ConnectLogEntry
hashCode() - Method in class io.confluent.logevents.connect.Context
hashCode() - Method in class io.confluent.logevents.connect.LogEventState
hashCode() - Method in class io.confluent.logevents.connect.RemoteConnectLogsConfiguration
hashCode() - Method in class io.confluent.logevents.connect.Summary.ConnectorErrorSummary
hashCode() - Method in class io.confluent.logevents.connect.Summary
hasSummary() - Method in class io.confluent.logevents.connect.ConnectLogEntry.Builder: .logs.Summary summary = 3;
hasSummary() - Method in class io.confluent.logevents.connect.ConnectLogEntry: .logs.Summary summary = 3;
hasSummary() - Method in interface io.confluent.logevents.connect.ConnectLogEntryOrBuilder: .logs.Summary summary = 3;

I

io.confluent.logevents.connect - package io.confluent.logevents.connect
isInitialized() - Method in class io.confluent.logevents.connect.ConnectLogEntry.Builder
isInitialized() - Method in class io.confluent.logevents.connect.ConnectLogEntry
isInitialized() - Method in class io.confluent.logevents.connect.Context.Builder
isInitialized() - Method in class io.confluent.logevents.connect.Context
isInitialized() - Method in class io.confluent.logevents.connect.Summary.Builder
isInitialized() - Method in class io.confluent.logevents.connect.Summary.ConnectorErrorSummary.Builder
isInitialized() - Method in class io.confluent.logevents.connect.Summary.ConnectorErrorSummary
isInitialized() - Method in class io.confluent.logevents.connect.Summary

L

LEVEL_FIELD_NUMBER - Static variable in class io.confluent.logevents.connect.ConnectLogEntry
LOG_EVENTS_DEDUPLICATE_ERRORS - Static variable in class io.confluent.logevents.connect.LogEventsConfig
LOG_EVENTS_FAILURE_EVENT_MAP_CLEANUP_TIME_DEFAULT - Static variable in class io.confluent.logevents.connect.LogEventsConfig
LOG_EVENTS_FAILURE_EVENT_RESET_TIME - Static variable in class io.confluent.logevents.connect.LogEventsConfig
LogEvents - Class in io.confluent.logevents.connect: LogEvents contains methods for constructing and emitting various types of Connect Log events.
LogEvents() - Constructor for class io.confluent.logevents.connect.LogEvents
logEventsConfig() - Method in class io.confluent.logevents.connect.LogEventsKafkaEmitter: Returns the initialized LogEventsConfig instance from the user configs.
LogEventsConfig - Class in io.confluent.logevents.connect: LogEventsConfig class defining configurations needed for capturing Connect log events.
LogEventsConfig(Map<?, ?>) - Constructor for class io.confluent.logevents.connect.LogEventsConfig
logEventsDeduplicateErrors() - Method in class io.confluent.logevents.connect.LogEventsConfig
LogEventsEmitter - Interface in io.confluent.logevents.connect: LogEventsEmitter interface provides an api to emit Log Events to any configured destination, from anywhere within the connect cluster.
LogEventsKafkaEmitter - Class in io.confluent.logevents.connect: LogEventsKafkaEmitter, used to emit log events from anywhere in connect cluster to a configured destination topic.
LogEventsKafkaEmitter() - Constructor for class io.confluent.logevents.connect.LogEventsKafkaEmitter
LogEventsKafkaEmitter(EventLogger, LogEventsConfig, String) - Constructor for class io.confluent.logevents.connect.LogEventsKafkaEmitter
LogEventState - Class in io.confluent.logevents.connect: Stores the state of Connect log events for a given connector/task id.
LogEventState(String, long, Time) - Constructor for class io.confluent.logevents.connect.LogEventState
logFailureEvent(Throwable) - Method in class io.confluent.logevents.connect.LogEventState: Checks if the throwable passed as parameter is eligible for being emitted as a connect log event.
logFailureEventResetTime() - Method in class io.confluent.logevents.connect.LogEventsConfig
LOGGER_BOOTSTRAP_SERVERS_CONFIG - Static variable in class io.confluent.logevents.connect.LogEventsConfig
LOGGER_CLIENT_ID_CONFIG - Static variable in class io.confluent.logevents.connect.LogEventsConfig
LOGGER_CLIENT_ID_DOC - Static variable in class io.confluent.logevents.connect.LogEventsConfig
LOGGER_CLOUD_EVENT_ENCODING_CONFIG - Static variable in class io.confluent.logevents.connect.LogEventsConfig
LOGGER_ENABLE_CONFIG - Static variable in class io.confluent.logevents.connect.LogEventsConfig
LOGGER_ENABLE_DOC - Static variable in class io.confluent.logevents.connect.LogEventsConfig
LOGGER_EVENT_EXPORTER_CLASS_CONFIG - Static variable in class io.confluent.logevents.connect.LogEventsConfig
LOGGER_EXPORTER_TYPE_CONFIG - Static variable in class io.confluent.logevents.connect.LogEventsConfig
LOGGER_EXPORTER_TYPE_DEFAULT - Static variable in class io.confluent.logevents.connect.LogEventsConfig
LOGGER_LOG_EVENTS_TOPIC_CONFIG - Static variable in class io.confluent.logevents.connect.LogEventsConfig
LOGGER_TOPIC_CREATE_CONFIG - Static variable in class io.confluent.logevents.connect.LogEventsConfig

M

mergeConnectorErrorSummary(Summary.ConnectorErrorSummary) - Method in class io.confluent.logevents.connect.Summary.Builder: .logs.Summary.ConnectorErrorSummary connector_error_summary = 1;
mergeContext(Context) - Method in class io.confluent.logevents.connect.ConnectLogEntry.Builder: .logs.Context context = 2;
mergeFrom(CodedInputStream, ExtensionRegistryLite) - Method in class io.confluent.logevents.connect.ConnectLogEntry.Builder
mergeFrom(CodedInputStream, ExtensionRegistryLite) - Method in class io.confluent.logevents.connect.Context.Builder
mergeFrom(CodedInputStream, ExtensionRegistryLite) - Method in class io.confluent.logevents.connect.Summary.Builder
mergeFrom(CodedInputStream, ExtensionRegistryLite) - Method in class io.confluent.logevents.connect.Summary.ConnectorErrorSummary.Builder
mergeFrom(Message) - Method in class io.confluent.logevents.connect.ConnectLogEntry.Builder
mergeFrom(Message) - Method in class io.confluent.logevents.connect.Context.Builder
mergeFrom(Message) - Method in class io.confluent.logevents.connect.Summary.Builder
mergeFrom(Message) - Method in class io.confluent.logevents.connect.Summary.ConnectorErrorSummary.Builder
mergeFrom(ConnectLogEntry) - Method in class io.confluent.logevents.connect.ConnectLogEntry.Builder
mergeFrom(Context) - Method in class io.confluent.logevents.connect.Context.Builder
mergeFrom(Summary) - Method in class io.confluent.logevents.connect.Summary.Builder
mergeFrom(Summary.ConnectorErrorSummary) - Method in class io.confluent.logevents.connect.Summary.ConnectorErrorSummary.Builder
mergeSummary(Summary) - Method in class io.confluent.logevents.connect.ConnectLogEntry.Builder: .logs.Summary summary = 3;
MESSAGE_FIELD_NUMBER - Static variable in class io.confluent.logevents.connect.Summary.ConnectorErrorSummary
MESSAGESUMMARY_NOT_SET - Enum constant in enum class io.confluent.logevents.connect.Summary.MessageSummaryCase

N

NAMED_BOOTSTRAP_SERVERS_CONFIG_ENABLED - Static variable in class io.confluent.logevents.connect.LogEventsConfig
NAMED_BOOTSTRAP_SERVERS_CONFIG_ENABLED_DEFAULT - Static variable in class io.confluent.logevents.connect.LogEventsConfig
NAMED_BOOTSTRAP_SERVERS_CONFIG_ENABLED_DOC - Static variable in class io.confluent.logevents.connect.LogEventsConfig
newBuilder() - Static method in class io.confluent.logevents.connect.ConnectLogEntry
newBuilder() - Static method in class io.confluent.logevents.connect.Context
newBuilder() - Static method in class io.confluent.logevents.connect.Summary.ConnectorErrorSummary
newBuilder() - Static method in class io.confluent.logevents.connect.Summary
newBuilder(ConnectLogEntry) - Static method in class io.confluent.logevents.connect.ConnectLogEntry
newBuilder(Context) - Static method in class io.confluent.logevents.connect.Context
newBuilder(Summary) - Static method in class io.confluent.logevents.connect.Summary
newBuilder(Summary.ConnectorErrorSummary) - Static method in class io.confluent.logevents.connect.Summary.ConnectorErrorSummary
newBuilderForType() - Method in class io.confluent.logevents.connect.ConnectLogEntry
newBuilderForType() - Method in class io.confluent.logevents.connect.Context
newBuilderForType() - Method in class io.confluent.logevents.connect.Summary.ConnectorErrorSummary
newBuilderForType() - Method in class io.confluent.logevents.connect.Summary

O

onReceiveCallback(RemoteConnectLogsConfiguration) - Method in class io.confluent.logevents.connect.LogEventsKafkaEmitter

P

parseDelimitedFrom(InputStream) - Static method in class io.confluent.logevents.connect.ConnectLogEntry
parseDelimitedFrom(InputStream) - Static method in class io.confluent.logevents.connect.Context
parseDelimitedFrom(InputStream) - Static method in class io.confluent.logevents.connect.Summary.ConnectorErrorSummary
parseDelimitedFrom(InputStream) - Static method in class io.confluent.logevents.connect.Summary
parseDelimitedFrom(InputStream, ExtensionRegistryLite) - Static method in class io.confluent.logevents.connect.ConnectLogEntry
parseDelimitedFrom(InputStream, ExtensionRegistryLite) - Static method in class io.confluent.logevents.connect.Context
parseDelimitedFrom(InputStream, ExtensionRegistryLite) - Static method in class io.confluent.logevents.connect.Summary.ConnectorErrorSummary
parseDelimitedFrom(InputStream, ExtensionRegistryLite) - Static method in class io.confluent.logevents.connect.Summary
parseFrom(byte[]) - Static method in class io.confluent.logevents.connect.ConnectLogEntry
parseFrom(byte[]) - Static method in class io.confluent.logevents.connect.Context
parseFrom(byte[]) - Static method in class io.confluent.logevents.connect.Summary.ConnectorErrorSummary
parseFrom(byte[]) - Static method in class io.confluent.logevents.connect.Summary
parseFrom(byte[], ExtensionRegistryLite) - Static method in class io.confluent.logevents.connect.ConnectLogEntry
parseFrom(byte[], ExtensionRegistryLite) - Static method in class io.confluent.logevents.connect.Context
parseFrom(byte[], ExtensionRegistryLite) - Static method in class io.confluent.logevents.connect.Summary.ConnectorErrorSummary
parseFrom(byte[], ExtensionRegistryLite) - Static method in class io.confluent.logevents.connect.Summary
parseFrom(ByteString) - Static method in class io.confluent.logevents.connect.ConnectLogEntry
parseFrom(ByteString) - Static method in class io.confluent.logevents.connect.Context
parseFrom(ByteString) - Static method in class io.confluent.logevents.connect.Summary.ConnectorErrorSummary
parseFrom(ByteString) - Static method in class io.confluent.logevents.connect.Summary
parseFrom(ByteString, ExtensionRegistryLite) - Static method in class io.confluent.logevents.connect.ConnectLogEntry
parseFrom(ByteString, ExtensionRegistryLite) - Static method in class io.confluent.logevents.connect.Context
parseFrom(ByteString, ExtensionRegistryLite) - Static method in class io.confluent.logevents.connect.Summary.ConnectorErrorSummary
parseFrom(ByteString, ExtensionRegistryLite) - Static method in class io.confluent.logevents.connect.Summary
parseFrom(CodedInputStream) - Static method in class io.confluent.logevents.connect.ConnectLogEntry
parseFrom(CodedInputStream) - Static method in class io.confluent.logevents.connect.Context
parseFrom(CodedInputStream) - Static method in class io.confluent.logevents.connect.Summary.ConnectorErrorSummary
parseFrom(CodedInputStream) - Static method in class io.confluent.logevents.connect.Summary
parseFrom(CodedInputStream, ExtensionRegistryLite) - Static method in class io.confluent.logevents.connect.ConnectLogEntry
parseFrom(CodedInputStream, ExtensionRegistryLite) - Static method in class io.confluent.logevents.connect.Context
parseFrom(CodedInputStream, ExtensionRegistryLite) - Static method in class io.confluent.logevents.connect.Summary.ConnectorErrorSummary
parseFrom(CodedInputStream, ExtensionRegistryLite) - Static method in class io.confluent.logevents.connect.Summary
parseFrom(InputStream) - Static method in class io.confluent.logevents.connect.ConnectLogEntry
parseFrom(InputStream) - Static method in class io.confluent.logevents.connect.Context
parseFrom(InputStream) - Static method in class io.confluent.logevents.connect.Summary.ConnectorErrorSummary
parseFrom(InputStream) - Static method in class io.confluent.logevents.connect.Summary
parseFrom(InputStream, ExtensionRegistryLite) - Static method in class io.confluent.logevents.connect.ConnectLogEntry
parseFrom(InputStream, ExtensionRegistryLite) - Static method in class io.confluent.logevents.connect.Context
parseFrom(InputStream, ExtensionRegistryLite) - Static method in class io.confluent.logevents.connect.Summary.ConnectorErrorSummary
parseFrom(InputStream, ExtensionRegistryLite) - Static method in class io.confluent.logevents.connect.Summary
parseFrom(ByteBuffer) - Static method in class io.confluent.logevents.connect.ConnectLogEntry
parseFrom(ByteBuffer) - Static method in class io.confluent.logevents.connect.Context
parseFrom(ByteBuffer) - Static method in class io.confluent.logevents.connect.Summary.ConnectorErrorSummary
parseFrom(ByteBuffer) - Static method in class io.confluent.logevents.connect.Summary
parseFrom(ByteBuffer, ExtensionRegistryLite) - Static method in class io.confluent.logevents.connect.ConnectLogEntry
parseFrom(ByteBuffer, ExtensionRegistryLite) - Static method in class io.confluent.logevents.connect.Context
parseFrom(ByteBuffer, ExtensionRegistryLite) - Static method in class io.confluent.logevents.connect.Summary.ConnectorErrorSummary
parseFrom(ByteBuffer, ExtensionRegistryLite) - Static method in class io.confluent.logevents.connect.Summary
parser() - Static method in class io.confluent.logevents.connect.ConnectLogEntry
parser() - Static method in class io.confluent.logevents.connect.Context
parser() - Static method in class io.confluent.logevents.connect.Summary.ConnectorErrorSummary
parser() - Static method in class io.confluent.logevents.connect.Summary

R

registerAllExtensions(ExtensionRegistry) - Static method in class io.confluent.logevents.connect.ConnectLogProto
registerAllExtensions(ExtensionRegistryLite) - Static method in class io.confluent.logevents.connect.ConnectLogProto
RemoteConnectLogsConfiguration - Class in io.confluent.logevents.connect: RemoteConnectLogsConfiguration is the configuration object for the remote auditlog config.
RemoteConnectLogsConfiguration(String, Map<Region, ConnectLogEventsConfig>) - Constructor for class io.confluent.logevents.connect.RemoteConnectLogsConfiguration
ROOT_CAUSE_FIELD_NUMBER - Static variable in class io.confluent.logevents.connect.Summary.ConnectorErrorSummary

S

setConnectorErrorSummary(Summary.ConnectorErrorSummary) - Method in class io.confluent.logevents.connect.Summary.Builder: .logs.Summary.ConnectorErrorSummary connector_error_summary = 1;
setConnectorErrorSummary(Summary.ConnectorErrorSummary.Builder) - Method in class io.confluent.logevents.connect.Summary.Builder: .logs.Summary.ConnectorErrorSummary connector_error_summary = 1;
setConnectorId(String) - Method in class io.confluent.logevents.connect.Context.Builder: string connector_id = 1;
setConnectorIdBytes(ByteString) - Method in class io.confluent.logevents.connect.Context.Builder: string connector_id = 1;
setContext(Context) - Method in class io.confluent.logevents.connect.ConnectLogEntry.Builder: .logs.Context context = 2;
setContext(Context.Builder) - Method in class io.confluent.logevents.connect.ConnectLogEntry.Builder: .logs.Context context = 2;
setLevel(String) - Method in class io.confluent.logevents.connect.ConnectLogEntry.Builder: string level = 1;
setLevelBytes(ByteString) - Method in class io.confluent.logevents.connect.ConnectLogEntry.Builder: string level = 1;
setMessage(String) - Method in class io.confluent.logevents.connect.Summary.ConnectorErrorSummary.Builder: string message = 1;
setMessageBytes(ByteString) - Method in class io.confluent.logevents.connect.Summary.ConnectorErrorSummary.Builder: string message = 1;
setRootCause(String) - Method in class io.confluent.logevents.connect.Summary.ConnectorErrorSummary.Builder: string root_cause = 2;
setRootCauseBytes(ByteString) - Method in class io.confluent.logevents.connect.Summary.ConnectorErrorSummary.Builder: string root_cause = 2;
setSummary(Summary) - Method in class io.confluent.logevents.connect.ConnectLogEntry.Builder: .logs.Summary summary = 3;
setSummary(Summary.Builder) - Method in class io.confluent.logevents.connect.ConnectLogEntry.Builder: .logs.Summary summary = 3;
shouldReset() - Method in class io.confluent.logevents.connect.LogEventState: Checks if reset window has elapsed since the error was last observed.
start(Map<String, ?>) - Method in class io.confluent.logevents.connect.LogEventsKafkaEmitter: Start up the event logger.
stop() - Method in class io.confluent.logevents.connect.LogEventsKafkaEmitter: Needs to be called only once during teardown of the worker.
Summary - Class in io.confluent.logevents.connect: Protobuf type logs.Summary
SUMMARY_FIELD_NUMBER - Static variable in class io.confluent.logevents.connect.ConnectLogEntry
Summary.Builder - Class in io.confluent.logevents.connect: Protobuf type logs.Summary
Summary.ConnectorErrorSummary - Class in io.confluent.logevents.connect: Protobuf type logs.Summary.ConnectorErrorSummary
Summary.ConnectorErrorSummary.Builder - Class in io.confluent.logevents.connect: Protobuf type logs.Summary.ConnectorErrorSummary
Summary.ConnectorErrorSummaryOrBuilder - Interface in io.confluent.logevents.connect
Summary.MessageSummaryCase - Enum Class in io.confluent.logevents.connect
SummaryOrBuilder - Interface in io.confluent.logevents.connect

T

toBuilder() - Method in class io.confluent.logevents.connect.ConnectLogEntry
toBuilder() - Method in class io.confluent.logevents.connect.Context
toBuilder() - Method in class io.confluent.logevents.connect.Summary.ConnectorErrorSummary
toBuilder() - Method in class io.confluent.logevents.connect.Summary
toEventLoggerConfig() - Method in class io.confluent.logevents.connect.LogEventsConfig: Return only configs prefixed by `confluent.event.logger` from LogEventsConfigs defaults as well as WorkerConfigs for LogEventsKafkaEmitter#eventLogger.
toString() - Method in class io.confluent.logevents.connect.LogEventsKafkaEmitter
toString() - Method in class io.confluent.logevents.connect.LogEventState

V

valueOf(int) - Static method in enum class io.confluent.logevents.connect.Summary.MessageSummaryCase: Deprecated.
valueOf(String) - Static method in enum class io.confluent.logevents.connect.Summary.MessageSummaryCase: Returns the enum constant of this class with the specified name.
values() - Static method in enum class io.confluent.logevents.connect.Summary.MessageSummaryCase: Returns an array containing the constants of this enum class, in the order they are declared.

W

writeTo(CodedOutputStream) - Method in class io.confluent.logevents.connect.ConnectLogEntry
writeTo(CodedOutputStream) - Method in class io.confluent.logevents.connect.Context
writeTo(CodedOutputStream) - Method in class io.confluent.logevents.connect.Summary.ConnectorErrorSummary
writeTo(CodedOutputStream) - Method in class io.confluent.logevents.connect.Summary

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