Interface LogEventsEmitter

All Known Implementing Classes:
LogEventsKafkaEmitter
public interface LogEventsEmitter
LogEventsEmitter interface provides an api to emit Log Events to any configured destination, from anywhere within the connect cluster. This is the main interface that will be used by LogEvents utility class to forward the Log Events to configured destination. Each Worker has a single LogEventsEmitter's implementation instantiated in it.

  • Method Summary

    Modifier and Type
    Method
    Description
    void
    emit(ConnectLogEntry connectLogEntry, String subject, String source, String type)
    Construct a connect Log Event and emit it to the preconfigured destination.

  • Method Details

    • emit

      void emit(ConnectLogEntry connectLogEntry, String subject, String source, String type)
      Construct a connect Log Event and emit it to the preconfigured destination.
      Parameters:
      connectLogEntry - Payload containing details of the connect log event. May not be null.
      subject - From CloudEvents spec. Subject captures what the event is about. May not be null.
      source - From CloudEvents spec. Source captures the context in which the event happened. May not be null.
      type - From CloudEvents spec. Identifies the event type. May not be null.