public class LogEvents extends Object
LogEventsEmitter
using which the events
are published to the destination topic.Constructor and Description |
---|
LogEvents() |
Modifier and Type | Method and Description |
---|---|
static void |
connectorFailedEvent(Supplier<LogEventsEmitter> logEventsEmitterSupplier,
String connectorId,
Throwable cause)
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. |
static void |
connectorTaskFailedEvent(Supplier<LogEventsEmitter> logEventsEmitterSupplier,
String connectorId,
String taskId,
Throwable cause)
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. |
public static void connectorFailedEvent(Supplier<LogEventsEmitter> logEventsEmitterSupplier, String connectorId, Throwable cause)
ConnectLogEntry
for a Connector failure event, and forwards the entry to
LogEventsEmitter
to emit it in the form of CloudEvent
to the
destination topic.logEventsEmitterSupplier
- Supplier of LogEventsEmitter
. May not be null.connectorId
- Id of the connector. May not be empty or null.cause
- Throwable instance, capturing Connector's failure. May not bepublic static void connectorTaskFailedEvent(Supplier<LogEventsEmitter> logEventsEmitterSupplier, String connectorId, String taskId, Throwable cause)
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.logEventsEmitterSupplier
- Supplier of LogEventsEmitter
. May not be null.connectorId
- Id of the connector. May not be empty or null.taskId
- Id of the task. May not be empty or null.cause
- Throwable instance, capturing Connector's failure. May