[GitHub] [pulsar] codelipenghui added a comment to the discussion: How to achieve the effect of maximum delay time in retransmission backoff mechanism

GitHub user codelipenghui added a comment to the discussion: How to achieve the effect of maximum delay time in retransmission backoff mechanism @startjava I have pushed out a PR to add the redelivery delay validation https://github.com/apache/pulsar/pull/18264 GitHub link: https://github.co

[GitHub] [pulsar] startjava added a comment to the discussion: How to achieve the effect of maximum delay time in retransmission backoff mechanism

GitHub user startjava added a comment to the discussion: How to achieve the effect of maximum delay time in retransmission backoff mechanism last effect every 10s redelivery GitHub link: https://github.com/apache/pulsar/discussions/18261#discussioncomment-4015288 This is an automaticall

[GitHub] [pulsar] startjava added a comment to the discussion: How to achieve the effect of maximum delay time in retransmission backoff mechanism

GitHub user startjava added a comment to the discussion: How to achieve the effect of maximum delay time in retransmission backoff mechanism but i run nack operate： @Component public class MyMessageListener1 implements MessageListener { @Override public void received(Consumer consumer,

[GitHub] [pulsar] startjava added a comment to the discussion: How to achieve the effect of maximum delay time in retransmission backoff mechanism

GitHub user startjava added a comment to the discussion: How to achieve the effect of maximum delay time in retransmission backoff mechanism every 10s。 GitHub link: https://github.com/apache/pulsar/discussions/18261#discussioncomment-4015260 This is an automatically sent email for dev@p

[GitHub] [pulsar] startjava edited a discussion: How to achieve the effect of maximum delay time in retransmission backoff mechanism

GitHub user startjava edited a discussion: How to achieve the effect of maximum delay time in retransmission backoff mechanism ``` @Bean public Consumer createPulsarConsumer_myTopic2() throws PulsarClientException { Consumer consumer = pulsarClient.newConsumer().topic(myTopic2

[GitHub] [pulsar] startjava edited a discussion: How to achieve the effect of maximum delay time in retransmission backoff mechanism

GitHub user startjava edited a discussion: How to achieve the effect of maximum delay time in retransmission backoff mechanism ``` @Bean public Consumer createPulsarConsumer_myTopic2() throws PulsarClientException { Consumer consumer = pulsarClient.newConsumer().topic(myTopic2

[GitHub] [pulsar] startjava added a comment to the discussion: How to achieve the effect of maximum delay time in retransmission backoff mechanism

GitHub user startjava added a comment to the discussion: How to achieve the effect of maximum delay time in retransmission backoff mechanism @codelipenghui i use shared subscription. top code i update . GitHub link: https://github.com/apache/pulsar/discussions/18261#discussioncomment-401524

[GitHub] [pulsar] codelipenghui added a comment to the discussion: How to achieve the effect of maximum delay time in retransmission backoff mechanism

GitHub user codelipenghui added a comment to the discussion: How to achieve the effect of maximum delay time in retransmission backoff mechanism @startjava Have you tried to use a Shared subscription? By default, Pulsar will use the exclusive subscription. Pulsar will not track the redelivery

[GitHub] [pulsar] startjava added a comment to the discussion: why "egatively acknowledged before the acknowledgment timeout"?? after Can't?

GitHub user startjava added a comment to the discussion: why "egatively acknowledged before the acknowledgment timeout"?? after Can't? @michaeljmarshall It means that the nack will be retransmitted twice after the ack timeout, and only once before the ack timeout? GitHub link: https://githu

[GitHub] [pulsar] startjava edited a discussion: How to achieve the effect of maximum delay time in retransmission backoff mechanism

GitHub user startjava edited a discussion: How to achieve the effect of maximum delay time in retransmission backoff mechanism ``` @Bean public Consumer createPulsarConsumer_myTopic5() throws PulsarClientException { Consumer consumer = pulsarClient.newConsumer().topic(myTopic5).subscriptio

Re: [DISCUSS] PIP-217: LoadShedding Strategy Improment

Hi, It looks like we move the bundle from one broker to another broker but doesn't move the historical load data of this bundle. I suppose this is the main cause of the problem. Thanks, Penghui On 2022/10/24 17:46:21 Heesung Sohn wrote: > Hi, > > Currently, the historical score is based on ex