+1 On Wed, Jan 5, 2022 at 12:12 AM Ran Gao <r...@apache.org> wrote:
> +1 > > Best, > Ran Gao > > On 2022/01/04 03:34:33 PengHui Li wrote: > > This is the voting thread for PIP-130. It will stay open for at least 48 > > hours. > > > > https://github.com/apache/pulsar/issues/13528 > > > > Pasted below for quoting convenience. > > > > ----- > > > > PIP 130: Apply redelivery backoff policy for ack timeout > > > > ## Motivation > > > > PIP 106 > > > https://github.com/apache/pulsar/wiki/PIP-106%3A-Negative-acknowledgment-backoff > > introduced negative acknowledgment message redelivery backoff which > allows > > users to achieve > > more flexible message redelivery delay time control. But the redelivery > > backoff policy only > > apply to the negative acknowledgment API, for users who use ack timeout > to > > trigger the message > > redelivery, not the negative acknowledgment API, they can't use the new > > features introduced by > > PIP 106. > > > > So the proposal is to apply the message redelivery policy for the ack > > timeout mechanism. > > Users can specify an ack timeout redelivery backoff, for example, apply > an > > exponential backoff > > with 10 seconds ack timeout: > > > > ```java > > client.newConsumer() > > .ackTimeout(10, TimeUnit.SECOND) > > .ackTimeoutRedeliveryBackoff( > > ExponentialRedeliveryBackoff.builder() > > .minDelayMs(1000) > > .maxDelayMs(60000).build()); > > .subscribe(); > > ``` > > > > The message redelivery behavior should be: > > > > | Redelivery count | Redelivery delay | > > | ---- | ---- | > > | 1 | 10 + 1 seconds | > > | 2 | 10 + 2 seconds | > > | 3 | 10 + 4 seconds | > > | 4 | 10 + 8 seconds | > > | 5 | 10 + 16 seconds | > > | 6 | 10 + 32 seconds | > > | 7 | 10 + 60 seconds | > > | 8 | 10 + 60 seconds | > > > > ## Goal > > > > Add an API to the Java Client to provide the ability to specify the ack > > timeout message redelivery > > backoff and the message redelivery behavior should abide by the > redelivery > > backoff policy. > > > > > > ## API Changes > > > > 1. Change `NegativeAckRedeliveryBackoff` to `RedeliveryBackoff`, so that > we > > can use the > > MessageRedeliveryBackoff for both negative acknowledgment API and ack > > timeout message redelivery. > > > > 2. Change `NegativeAckRedeliveryExponentialBackoff` to > > `ExponentialRedeliveryBackoff`, and add `multiplier` > > for `RedeliveryExponentialBackoff` with default value 2. > > > > ExponentialRedeliveryBackoff.builder() > > .minDelayMs(1000) > > .maxDelayMs(60000) > > .multiplier(5) > > .build() > > > > 3. Add `ackTimeoutRedeliveryBackoff` method for the `ConsumerBuilder`: > > > > ```java > > client.newConsumer() > > .ackTimeout(10, TimeUnit.SECOND) > > .ackTimeoutRedeliveryBackoff( > > ExponentialRedeliveryBackoff.builder() > > .minDelayMs(1000) > > .maxDelayMs(60000).build()); > > .subscribe(); > > ``` > > > > ## Compatibility and migration plan > > > > Since the negative acknowledgment message, redelivery backoff has not > been > > released yet, > > so we can modify the API directly. > > > > ## Tests plan > > > > - Verify the introduced `multiplier` of ExponentialRedeliveryBackoff > > - Verify the ack timeout message redelivery work as expected > > > > Regards, > > Penghui > > >
