public class LogEventState extends Object
Constructor and Description |
---|
LogEventState(String id,
long logFailureEventResetTime,
org.apache.kafka.common.utils.Time time) |
Modifier and Type | Method and Description |
---|---|
boolean |
equals(Object o) |
int |
hashCode() |
boolean |
logFailureEvent(Throwable error)
Checks if the throwable passed as parameter is eligible for being emitted as a connect log
event.
|
boolean |
shouldReset()
Checks if reset window has elapsed since the error was last observed.
|
String |
toString() |
public LogEventState(String id, long logFailureEventResetTime, org.apache.kafka.common.utils.Time time)
public boolean logFailureEvent(Throwable error)
error
- Throwable instance which needs to be checked against cached throwable to detect
duplicatespublic boolean shouldReset()