Class ExceptionCaptorNotifier

  • All Implemented Interfaces:
    VeniceNotifier,, java.lang.AutoCloseable

    public class ExceptionCaptorNotifier
    extends LogNotifier
    • Constructor Detail

      • ExceptionCaptorNotifier

        public ExceptionCaptorNotifier()
    • Method Detail

      • error

        public void error​(java.lang.String kafkaTopic,
                          int partitionId,
                          java.lang.String message,
                          java.lang.Exception ex)
        Description copied from interface: VeniceNotifier
        Report an error, during the consumption for a Partitions and store. The error may or may not be fatal.
        Specified by:
        error in interface VeniceNotifier
        error in class LogNotifier
      • getLatestException

        public java.lang.Exception getLatestException()