Sarama retry since v8.5.7 may make the sink stuck forever on transient error
Open
@3AceShowHand is already working on this.
Since Aug 19, 2026.
type/bug
- Dominant language
- Go
- Stars
- 56
- Forks
- 63
- Avg merge
- 2d 20h
- Merged PRs (30d)
- 34
Description
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
Contributor guide
First steps
- Read the whole issue, then the project's contributing guide.
- Comment on the issue to say you are picking it up — it saves two people doing the same work.
- Fork the repository and make your change on a branch.
- Open a pull request that references the issue number.
Assessment
This issue has not been assessed yet.