Skip to content

Sarama retry since v8.5.7 may make the sink stuck forever on transient error #6041

Description

@kennytm

What did you do?

  • Create a Kafka changefeed
  • Keep writing data until the Kafka reported some transient errors ("broken pipe" etc) (?)

What did you expect to see?

  • Automatic retry allowed the message to be written.

What did you see instead?

  • The sink is stuck not confirming success or failure, and thus CheckpointTS is stuck.

Versions of the cluster

v8.5.7

Metadata

Metadata

Assignees

Labels

type/bugThe issue is confirmed as a bug.

Type

No type

Projects

No projects

Milestone

No milestone

Relationships

None yet

Development

No branches or pull requests

Issue actions