Currently, manually pausing a partition requires setting pause-if-no-requests=false, which disables backpressure and can lead to OOM errors as the application continues to buffer messages.
Users need a strategy to pause specific partitions during failure while keeping pause-if-no-requests=true to maintain system stability.
This requires the Kafka connector to maintain an internal list of manually paused partitions that are excluded from the automatic resume logic.
Currently, manually pausing a partition requires setting
pause-if-no-requests=false, which disables backpressure and can lead to OOM errors as the application continues to buffer messages.Users need a strategy to pause specific partitions during failure while keeping
pause-if-no-requests=trueto maintain system stability.This requires the Kafka connector to maintain an internal list of manually paused partitions that are excluded from the automatic resume logic.