com.ververica.cdc.connectors.mysql.debezium.task.context

Class MySqlErrorHandler

java.lang.Object

io.debezium.pipeline.ErrorHandler

com.ververica.cdc.connectors.mysql.debezium.task.context.MySqlErrorHandler

public class MySqlErrorHandler
extends io.debezium.pipeline.ErrorHandler

A subclass implementation of ErrorHandler which filter some DebeziumException, we use this class instead of MySqlErrorHandler.

Constructor Summary

Constructors

Constructor and Description
MySqlErrorHandler(String logicalName, io.debezium.connector.base.ChangeEventQueue<?> queue, io.debezium.connector.mysql.MySqlTaskContext context)

Method Summary

Modifier and Type	Method and Description
protected boolean	isRetriable(Throwable throwable)
void	setProducerThrowable(Throwable producerThrowable)

Methods inherited from class io.debezium.pipeline.ErrorHandler

getProducerThrowable

Methods inherited from class java.lang.Object

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

Constructor Detail

MySqlErrorHandler

public MySqlErrorHandler(String logicalName,
                         io.debezium.connector.base.ChangeEventQueue<?> queue,
                         io.debezium.connector.mysql.MySqlTaskContext context)

Method Detail

isRetriable

protected boolean isRetriable(Throwable throwable)

Overrides:

isRetriable in class io.debezium.pipeline.ErrorHandler

setProducerThrowable

public void setProducerThrowable(Throwable producerThrowable)

Overrides:

setProducerThrowable in class io.debezium.pipeline.ErrorHandler