Debezium kakfa connectors retriable errors
Srikanth Kantamaneni
Hi Team
I have observed that there is a feature for auto restart of kafka connectors when the error is retriable. To check whether the error is retriable or not, there is method isRetriable is defined in SqlServerErrorHandler class. Debezium-core is also having the same method defined but always returns false. Even though isRetriable method is available in SqlServerErrorHandler class, it isn’t used instead the method from debezium-core is being used.
Is it intentional to use the debezium-core’s method instead of its own ErrorHandler class method. Or is that feature developed and yet to be released in future versions.
SqlServer class where ErrorHandler class from debezium-core is being used: https://github.com/debezium/debezium/blob/1.6/debezium-connector-sqlserver/src/main/java/io/debezium/connector/sqlserver/SqlServerStreamingChangeEventSource.java#L28
Debezium-core method where it always returns false: https://github.com/debezium/debezium/blob/1.6/debezium-core/src/main/java/io/debezium/pipeline/ErrorHandler.java#L55-L58
Same method from SqlServerErrorHandler class where the error check is happening: https://github.com/debezium/debezium/blob/1.6/debezium-connector-sqlserver/src/main/java/io/debezium/connector/sqlserver/SqlServerErrorHandler.java#L25-L42
Thank You
Srikanth
