Sink: Retry failed writes until user-defined timeout expires
Description
Environment
None
Gerrit Reviews
None
Release Notes Description
None
is duplicated by
Activity
Show:
Fixed
Pinned fields
Click on the next to a field label to start pinning.
Details
Details
Assignee
David NaultReporter
David NaultStory Points
1
Fix versions
Priority
MajorInstabug
Open Instabug
PagerDuty
PagerDuty Incident
PagerDuty
PagerDuty Incident
Sentry
Linked Issues
Sentry
Linked Issues
Zendesk Support
Linked Tickets
Zendesk Support
Linked Tickets
Created November 2, 2021 at 8:18 PM
Updated May 6, 2022 at 12:48 AM
Resolved November 5, 2021 at 7:44 PM
Instabug
The Kafka connector currently uses the Java SDK's default retry strategy, which considers some kinds of failures to be unretryable (particularly the kinds of failures that occur during a Couchbase failover/rebalance).
Instead, we want the connector to retry writes that fail for any reason until a user-configured timeout duration expires.