Package io.confluent.telemetry.events

Class EventEmitterImpl

java.lang.Object
io.confluent.telemetry.events.EventEmitterImpl
All Implemented Interfaces:
io.confluent.telemetry.api.events.EventEmitter, AutoCloseable, org.apache.kafka.common.Configurable
public class EventEmitterImpl extends Object implements io.confluent.telemetry.api.events.EventEmitter, org.apache.kafka.common.Configurable

  • Constructor Details

    • EventEmitterImpl

      public EventEmitterImpl(Map<String,?> configs)

  • Method Details

    • emit

      public CompletableFuture<Boolean> emit(io.confluent.telemetry.api.events.Event event)
      Specified by:
      emit in interface io.confluent.telemetry.api.events.EventEmitter

    • setEventLabels

      public void setEventLabels(Map<String,String> labels)

    • configure

      public final void configure(Map<String,?> configs)
      Specified by:
      configure in interface org.apache.kafka.common.Configurable

    • close

      public void close()
      Specified by:
      close in interface AutoCloseable