Package org.apache.kafka.clients.consumer.internals.events

Interface EventProcessor.ProcessHandler<T>

Enclosing class:
EventProcessor<T>
protected static interface EventProcessor.ProcessHandler<T>

  • Method Summary

    Modifier and Type
    Method
    Description
    void
    onProcess(T event, Optional<org.apache.kafka.common.KafkaException> error)
     

  • Method Details

    • onProcess

      void onProcess(T event, Optional<org.apache.kafka.common.KafkaException> error)