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, Message msg) {
String messageValue = new String(msg.getData());
messageValue = messageValue.split("\\_")[0];
System.out.println(System.currentTimeMillis() + " MyMessageListener1="
+ messageValue);
consumer.negativeAcknowledge(msg);
}
}
print time info :
1667190365861 MyMessageListener1=我是消息4
1667190366883 MyMessageListener1=我是消息4
1667190369261 MyMessageListener1=我是消息4
1667190373664 MyMessageListener1=我是消息4
2022-10-31 12:26:16.697 INFO 16612 --- [ulsar-timer-6-1]
o.a.p.client.impl.UnAckedMessageTracker :
[ConsumerBase{subscription='myTopic2_subscriptionName1', consumerName='7846e',
topic='myTopic2'}] 1 messages will be re-delivered
1667190376740 MyMessageListener1=我是消息4
2022-10-31 12:26:27.715 INFO 16612 --- [ulsar-timer-6-1]
o.a.p.client.impl.UnAckedMessageTracker :
[ConsumerBase{subscription='myTopic2_subscriptionName1', consumerName='7846e',
topic='myTopic2'}] 1 messages will be re-delivered
1667190387881 MyMessageListener1=我是消息4
2022-10-31 12:26:38.733 INFO 16612 --- [ulsar-timer-6-1]
o.a.p.client.impl.UnAckedMessageTracker :
[ConsumerBase{subscription='myTopic2_subscriptionName1', consumerName='7846e',
topic='myTopic2'}] 1 messages will be re-delivered
1667190399052 MyMessageListener1=我是消息4
2022-10-31 12:26:49.748 INFO 16612 --- [ulsar-timer-6-1]
o.a.p.client.impl.UnAckedMessageTracker :
[ConsumerBase{subscription='myTopic2_subscriptionName1', consumerName='7846e',
topic='myTopic2'}] 1 messages will be re-delivered
1667190410015 MyMessageListener1=我是消息4
2022-10-31 12:26:58.666 INFO 16612 --- [ulsar-timer-6-1]
o.a.p.c.impl.ConsumerStatsRecorderImpl : [myTopic2]
[myTopic2_subscriptionName1] [7846e] Prefetched messages: 0 --- Consume
throughput received: 0.13 msgs/s --- 0.00 Mbit/s --- Ack sent rate: 0.00 ack/s
--- Failed messages: 0 --- batch messages: 0 ---Failed acks: 0
2022-10-31 12:27:00.764 INFO 16612 --- [ulsar-timer-6-1]
o.a.p.client.impl.UnAckedMessageTracker :
[ConsumerBase{subscription='myTopic2_subscriptionName1', consumerName='7846e',
topic='myTopic2'}] 1 messages will be re-delivered
1667190420815 MyMessageListener1=我是消息4
2022-10-31 12:27:11.780 INFO 16612 --- [ulsar-timer-6-1]
o.a.p.client.impl.UnAckedMessageTracker :
[ConsumerBase{subscription='myTopic2_subscriptionName1', consumerName='7846e',
topic='myTopic2'}] 1 messages will be re-delivered
1667190431887 MyMessageListener1=我是消息4
2022-10-31 12:27:22.794 INFO 16612 --- [ulsar-timer-6-1]
o.a.p.client.impl.UnAckedMessageTracker :
[ConsumerBase{subscription='myTopic2_subscriptionName1', consumerName='7846e',
topic='myTopic2'}] 1 messages will be re-delivered
1667190442939 MyMessageListener1=我是消息4
2022-10-31 12:27:33.809 INFO 16612 --- [ulsar-timer-6-1]
o.a.p.client.impl.UnAckedMessageTracker :
[ConsumerBase{subscription='myTopic2_subscriptionName1', consumerName='7846e',
topic='myTopic2'}] 1 messages will be re-delivered
1667190453890 MyMessageListener1=我是消息4
2022-10-31 12:27:44.825 INFO 16612 --- [ulsar-timer-6-1]
o.a.p.client.impl.UnAckedMessageTracker :
[ConsumerBase{subscription='myTopic2_subscriptionName1', consumerName='7846e',
topic='myTopic2'}] 1 messages will be re-delivered
1667190465176 MyMessageListener1=我是消息4
2022-10-31 12:27:55.838 INFO 16612 --- [ulsar-timer-6-1]
o.a.p.client.impl.UnAckedMessageTracker :
[ConsumerBase{subscription='myTopic2_subscriptionName1', consumerName='7846e',
topic='myTopic2'}] 1 messages will be re-delivered
1667190476165 MyMessageListener1=我是消息4
2022-10-31 12:27:58.667 INFO 16612 --- [ulsar-timer-6-1]
o.a.p.c.impl.ConsumerStatsRecorderImpl : [myTopic2]
[myTopic2_subscriptionName1] [7846e] Prefetched messages: 0 --- Consume
throughput received: 0.10 msgs/s --- 0.00 Mbit/s --- Ack sent rate: 0.00 ack/s
--- Failed messages: 0 --- batch messages: 0 ---Failed acks: 0
2022-10-31 12:28:06.856 INFO 16612 --- [ulsar-timer-6-1]
o.a.p.client.impl.UnAckedMessageTracker :
[ConsumerBase{subscription='myTopic2_subscriptionName1', consumerName='7846e',
topic='myTopic2'}] 1 messages will be re-delivered
1667190486986 MyMessageListener1=我是消息4
GitHub link:
https://github.com/apache/pulsar/discussions/18261#discussioncomment-4015272
----
This is an automatically sent email for [email protected].
To unsubscribe, please send an email to: [email protected]
