Search before asking

• I searched in the issues and found nothing similar.

Motivation

Introduce batchDeliveryTimeout in client to expire batches that have been stuck for a long time. The purpose of this approach is to enable our Flink job to recover the write operation by restarting the client via failover. Otherwise, the client may not be able to recover itself, especially when an unrecoverable out-of-order issue occurs due to the server going down unexpectedly.

Solution

No response

Anything else?

No response

Willingness to contribute

• I'm willing to submit a PR!