In order to make your issue reports as actionable as possible, please provide the following information, depending on the issue type.

Bug report

For bug reports, provide this information, please:

What Debezium connector do you use and what version?

debezium-server-dist-2.6.0-SNAPSHOT

What behaviour do you expect?

The kinesis sink catches the exception when it has any errors when sending the records to kinesis through the putRecord method. After that, it has to retry.

What behaviour do you see?

The type of the exception is incorrect, so the code will never catch it, which will produce an error and kill the debezium-server thread, not working the retry mechanism.

Do you see the same behaviour using the latest relesead Debezium version?

(Ideally, also verify with latest Alpha/Beta/CR version)

Yes.

Implementation ideas (optional)

Change the exception to "KinesisException" instead of "SdkClientException".