Package com.linkedin.venice.utils

Class ExceptionCaptorNotifier

java.lang.Object

com.linkedin.davinci.notifier.LogNotifier

com.linkedin.venice.utils.ExceptionCaptorNotifier

All Implemented Interfaces:

VeniceNotifier, java.io.Closeable, java.lang.AutoCloseable

public class ExceptionCaptorNotifier
extends LogNotifier

Constructor Summary

Constructors

Constructor	Description
ExceptionCaptorNotifier()

Method Summary

Modifier and Type	Method	Description
void	error(java.lang.String kafkaTopic, int partitionId, java.lang.String message, java.lang.Exception ex)	Report an error, during the consumption for a Partitions and store.
java.lang.Exception	getLatestException()

Methods inherited from class com.linkedin.davinci.notifier.LogNotifier

catchUpVersionTopicOffsetLag, close, completed, dataRecoveryCompleted, endOfIncrementalPushReceived, endOfPushReceived, progress, restarted, started, startOfIncrementalPushReceived, stopped, topicSwitchReceived

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface com.linkedin.davinci.notifier.VeniceNotifier

batchEndOfIncrementalPushReceived, completed, endOfIncrementalPushReceived, endOfPushReceived, progress, quotaNotViolated, quotaNotViolated, quotaViolated, quotaViolated, restarted, started, startOfIncrementalPushReceived, topicSwitchReceived

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

Overrides:

error in class LogNotifier

getLatestException

public java.lang.Exception getLatestException()