Uploaded image for project: 'Debezium'
  1. Debezium
  2. DBZ-7417

Kinesis Sink Exception on PutRecord

XMLWordPrintable

    • False
    • None
    • False
    • Important

      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".

            [DBZ-7417] Kinesis Sink Exception on PutRecord

            Debezium Builder added a comment -

            Released

            Debezium Builder added a comment - Released

            Breno Moreira (Inactive) added a comment -

            I've already sent the pull request for that - https://github.com/debezium/debezium-server/pull/64

            Breno Moreira (Inactive) added a comment - I've already sent the pull request for that - https://github.com/debezium/debezium-server/pull/64

              Unassigned Unassigned
              brenoavm Breno Moreira (Inactive)
              Votes:
              0 Vote for this issue
              Watchers:
              3 Start watching this issue

                Created:
                Updated:
                Resolved: