Skip to content

changefeedccl: better handle kafka quotas #92290

@amruss

Description

@amruss

Kafka users can set a data quota in kafka. As a high throughput, high scale database, we can easily run up on those quotas. Customers cannot have an arbitrarily large kafka cluster to handle traffic bursts.

Likely what we want to do is:

  • exponentially backoff when we see a quota exceeded error from kafka (for the length of time kafka tells us to?)
  • implement pushback in this case ^

We should also add end-to-end testing for the scenario where kafka is purposely slow

Jira issue: CRDB-21692

Epic CRDB-21691

Metadata

Metadata

Assignees

Labels

C-enhancementSolution expected to add code/behavior + preserve backward-compat (pg compat issues are exception)T-cdc

Type

No type

Projects

Relationships

None yet

Development

No branches or pull requests

Issue actions