Skip to content

Kafka Connect: Add bounded retry for transient commit exceptions #16393

@yadavay-amzn

Description

@yadavay-amzn

Follow-up from #16237 (per @AnatolyPopov and @laskoviymishka review).

Currently, any full-commit failure immediately terminates the coordinator. For transient errors (e.g., CommitFailedException from catalog contention), bounded retries would avoid unnecessary operator intervention.

Proposal: add a configurable consecutive-failure threshold (e.g., 3). Only terminate the coordinator after N consecutive failures of the same commit cycle.

Willingness to contribute

  • I can contribute this fix independently

Metadata

Metadata

Assignees

No one assigned

    Labels

    No labels
    No labels

    Type

    No type
    No fields configured for issues without a type.

    Projects

    No projects

    Milestone

    No milestone

    Relationships

    None yet

    Development

    No branches or pull requests

    Issue actions