在订阅模式为Durable下丢失消息是不是和这个属性有关呢

源代码中的属性是:receiverQueueRefillThreshold

我在测试订阅模式为Durable,步骤如下:
(1)删除测试用的主题:
[ghy@localhost bin]$ ./pulsar-admin topics delete myTopic1
[ghy@localhost bin]$ ./pulsar-admin topics delete myTopic2
(2)启动生产者模块。
(3)启动消费者模块。
(4)执行如下网址,作用是生产30个消息:
http://localhost:8085/sendMessage1
大约是在消费第3个或第4个或第5个消息时快速停止Pulsar进程或断开与Pulsar服务器的网络连接。
(5)消费者控制台输出结果如下:
对消息:我是消息1,执行了ACK确认操作

对消息:我是消息2,执行了ACK确认操作

对消息:我是消息3,执行了ACK确认操作

对消息:我是消息4,执行了ACK确认操作

对消息:我是消息5,执行了ACK确认操作

对消息:我是消息6,执行了ACK确认操作

对消息:我是消息7,执行了ACK确认操作

对消息:我是消息8,执行了ACK确认操作

对消息:我是消息9,执行了ACK确认操作

对消息:我是消息10,执行了ACK确认操作

对消息:我是消息11,执行了ACK确认操作

对消息:我是消息12,执行了ACK确认操作

对消息:我是消息13,执行了ACK确认操作

WARN 35180 — [r-client-io-1-1] org.apache.pulsar.client.impl.ClientCnx : [/192.168.3.84:6650] Got exception java.io.IOException: 远程主机强迫关闭了一个现有的连接。

对消息:我是消息14,执行了ACK确认操作

对消息:我是消息15,执行了ACK确认操作

对消息:我是消息16,执行了ACK确认操作

对消息:我是消息17,执行了ACK确认操作

WARN 35180 — [r-client-io-1-1] org.apache.pulsar.client.impl.ClientCnx : [/192.168.3.84:6650] Got exception java.io.IOException: 远程主机强迫关闭了一个现有的连接。

对消息:我是消息18,执行了ACK确认操作

对消息:我是消息19,执行了ACK确认操作

对消息:我是消息20,执行了ACK确认操作

WARN 35180 — [r-client-io-1-1] o.a.pulsar.client.impl.ConnectionPool : Failed to open connection to 192.168.3.84:6650 : org.apache.pulsar.shade.io.netty.channel.ConnectTimeoutException: connection timed out: /192.168.3.84:6650

(6)等待几分钟后再恢复网络连接。
(7)消费者控制台输出如下结果:
对消息:我是消息6,执行了ACK确认操作
对消息:我是消息7,执行了ACK确认操作
对消息:我是消息8,执行了ACK确认操作
对消息:我是消息9,执行了ACK确认操作
对消息:我是消息10,执行了ACK确认操作
对消息:我是消息11,执行了ACK确认操作
对消息:我是消息12,执行了ACK确认操作
对消息:我是消息13,执行了ACK确认操作
对消息:我是消息14,执行了ACK确认操作
对消息:我是消息15,执行了ACK确认操作
对消息:我是消息21,执行了ACK确认操作
对消息:我是消息22,执行了ACK确认操作
对消息:我是消息23,执行了ACK确认操作
对消息:我是消息24,执行了ACK确认操作
对消息:我是消息25,执行了ACK确认操作
对消息:我是消息26,执行了ACK确认操作
对消息:我是消息27,执行了ACK确认操作
对消息:我是消息28,执行了ACK确认操作
对消息:我是消息29,执行了ACK确认操作
对消息:我是消息30,执行了ACK确认操作

消失的消息是:16到20,是不是和receiverQueueRefillThreshold有关呢?

这是否是一个bug呢,至少我感觉是这样的,因为没有ACK过的消息不可能出现丢失的现象。

对了,我的接收队列大小为20:
receiverQueueSize(20)

2022-10-24 23:13:38.694 DEBUG 8108 — [r-client-io-1-1] PersistentAcknowledgmentsGroupingTracker : [ConsumerBase{subscription=‘myTopic1_subscriptionName1’, consumerName=‘81946’, topic=‘myTopic1’}] Cannot flush pending acks since we’re not connected to broker
2022-10-24 23:13:38.696 INFO 8108 — [ulsar-timer-6-1] o.a.p.client.impl.ConnectionHandler : [myTopic2] [myTopic2_subscriptionName1] Reconnecting after connection was closed
2022-10-24 23:13:38.696 DEBUG 8108 — [ulsar-timer-6-1] o.a.pulsar.client.impl.ConnectionPool : Connection for 192.168.3.84:6650 not found in cache
2022-10-24 23:13:38.764 DEBUG 8108 — [r-client-io-1-1] PersistentAcknowledgmentsGroupingTracker : [ConsumerBase{subscription=‘myTopic2_subscriptionName1’, consumerName=‘d0602’, topic=‘myTopic2’}] Cannot flush pending acks since we’re not connected to broker
2022-10-24 23:13:38.796 DEBUG 8108 — [r-client-io-1-1] PersistentAcknowledgmentsGroupingTracker : [ConsumerBase{subscription=‘myTopic1_subscriptionName1’, consumerName=‘81946’, topic=‘myTopic1’}] Cannot flush pending acks since we’re not connected to broker
2022-10-24 23:13:38.829 INFO 8108 — [r-client-io-1-1] o.a.pulsar.client.impl.ConnectionPool : [[id: 0xe3b18348, L:/192.168.3.188:56313 - R:/192.168.3.84:6650]] Connected to server
2022-10-24 23:13:38.829 DEBUG 8108 — [r-client-io-1-1] o.a.p.common.protocol.PulsarHandler : [[id: 0xe3b18348, L:/192.168.3.188:56313 - R:/192.168.3.84:6650]] Scheduling keep-alive task every 30 s
2022-10-24 23:13:38.829 DEBUG 8108 — [r-client-io-1-1] org.apache.pulsar.client.impl.ClientCnx : [id: 0xe3b18348, L:/192.168.3.188:56313 - R:/192.168.3.84:6650] Connected to broker
2022-10-24 23:13:38.830 DEBUG 8108 — [r-client-io-1-1] org.apache.pulsar.client.impl.ClientCnx : Complete: true
2022-10-24 23:13:38.833 DEBUG 8108 — [r-client-io-1-1] o.a.p.common.protocol.PulsarDecoder : [/192.168.3.84:6650] Received cmd CONNECTED
2022-10-24 23:13:38.833 DEBUG 8108 — [r-client-io-1-1] org.apache.pulsar.client.impl.ClientCnx : [id: 0xe3b18348, L:/192.168.3.188:56313 - R:/192.168.3.84:6650] Connection has max message size setting, replace old frameDecoder with server frame size 5242880
2022-10-24 23:13:38.833 DEBUG 8108 — [r-client-io-1-1] org.apache.pulsar.client.impl.ClientCnx : [id: 0xe3b18348, L:/192.168.3.188:56313 - R:/192.168.3.84:6650] Connection is ready
2022-10-24 23:13:38.833 DEBUG 8108 — [r-client-io-1-1] o.a.pulsar.client.impl.ConnectionPool : [[id: 0xe3b18348, L:/192.168.3.188:56313 - R:/192.168.3.84:6650]] Connection handshake completed
2022-10-24 23:13:38.839 DEBUG 8108 — [r-client-io-1-1] o.a.p.common.protocol.PulsarDecoder : [/192.168.3.84:6650] Received cmd LOOKUP_RESPONSE
2022-10-24 23:13:38.840 DEBUG 8108 — [r-client-io-1-1] org.apache.pulsar.client.impl.ClientCnx : Received Broker lookup response: 3532537564388470844 Connect
2022-10-24 23:13:38.840 DEBUG 8108 — [r-client-io-1-1] o.a.pulsar.client.impl.ConnectionPool : Connection for localhost:6650 not found in cache
2022-10-24 23:13:38.846 INFO 8108 — [r-client-io-1-1] o.a.pulsar.client.impl.ConnectionPool : [[id: 0x7947367d, L:/192.168.3.188:56314 - R:/192.168.3.84:6650]] Connected to server
2022-10-24 23:13:38.847 DEBUG 8108 — [r-client-io-1-1] o.a.p.common.protocol.PulsarHandler : [[id: 0x7947367d, L:/192.168.3.188:56314 - R:/192.168.3.84:6650]] Scheduling keep-alive task every 30 s
2022-10-24 23:13:38.847 INFO 8108 — [r-client-io-1-1] org.apache.pulsar.client.impl.ClientCnx : [id: 0x7947367d, L:/192.168.3.188:56314 - R:/192.168.3.84:6650] Connected through proxy to target broker at localhost:6650
2022-10-24 23:13:38.848 DEBUG 8108 — [r-client-io-1-1] org.apache.pulsar.client.impl.ClientCnx : Complete: true
2022-10-24 23:13:38.864 DEBUG 8108 — [r-client-io-1-1] PersistentAcknowledgmentsGroupingTracker : [ConsumerBase{subscription=‘myTopic2_subscriptionName1’, consumerName=‘d0602’, topic=‘myTopic2’}] Cannot flush pending acks since we’re not connected to broker
2022-10-24 23:13:38.896 DEBUG 8108 — [r-client-io-1-1] PersistentAcknowledgmentsGroupingTracker : [ConsumerBase{subscription=‘myTopic1_subscriptionName1’, consumerName=‘81946’, topic=‘myTopic1’}] Cannot flush pending acks since we’re not connected to broker
2022-10-24 23:13:38.966 DEBUG 8108 — [r-client-io-1-1] o.a.p.common.protocol.PulsarDecoder : [/192.168.3.84:6650] Received cmd CONNECTED
2022-10-24 23:13:38.966 DEBUG 8108 — [r-client-io-1-1] org.apache.pulsar.client.impl.ClientCnx : [id: 0x7947367d, L:/192.168.3.188:56314 - R:/192.168.3.84:6650] Connection has max message size setting, replace old frameDecoder with server frame size 5242880
2022-10-24 23:13:38.966 DEBUG 8108 — [r-client-io-1-1] org.apache.pulsar.client.impl.ClientCnx : [id: 0x7947367d, L:/192.168.3.188:56314 - R:/192.168.3.84:6650] Connection is ready
2022-10-24 23:13:38.966 DEBUG 8108 — [r-client-io-1-1] o.a.pulsar.client.impl.ConnectionPool : [[id: 0x7947367d, L:/192.168.3.188:56314 - R:/192.168.3.84:6650]] Connection handshake completed
2022-10-24 23:13:38.966 INFO 8108 — [r-client-io-1-1] o.a.pulsar.client.impl.ConsumerImpl : [myTopic2][myTopic2_subscriptionName1] Subscribing to topic on cnx [id: 0x7947367d, L:/192.168.3.188:56314 - R:/192.168.3.84:6650], consumerId 1
2022-10-24 23:13:38.975 DEBUG 8108 — [r-client-io-1-1] o.a.p.common.protocol.PulsarDecoder : [/192.168.3.84:6650] Received cmd SUCCESS
2022-10-24 23:13:38.976 DEBUG 8108 — [r-client-io-1-1] org.apache.pulsar.client.impl.ClientCnx : [id: 0x7947367d, L:/192.168.3.188:56314 - R:/192.168.3.84:6650] Received success response from server: 3532537564388470845
2022-10-24 23:13:38.976 INFO 8108 — [r-client-io-1-1] o.a.pulsar.client.impl.ConsumerImpl : [myTopic2][myTopic2_subscriptionName1] Subscribed to topic on /192.168.3.84:6650 – consumer: 1
2022-10-24 23:13:38.976 DEBUG 8108 — [r-client-io-1-1] o.a.pulsar.client.impl.ConsumerImpl : [myTopic2] [myTopic2_subscriptionName1] Adding 20 additional permits
2022-10-24 23:13:38.977 DEBUG 8108 — [r-client-io-1-1] o.a.pulsar.client.impl.ConsumerImpl : Consumer 1 sent 20 permits to broker
2022-10-24 23:13:38.997 DEBUG 8108 — [r-client-io-1-1] PersistentAcknowledgmentsGroupingTracker : [ConsumerBase{subscription=‘myTopic1_subscriptionName1’, consumerName=‘81946’, topic=‘myTopic1’}] Cannot flush pending acks since we’re not connected to broker
2022-10-24 23:13:39.098 DEBUG 8108 — [r-client-io-1-1] PersistentAcknowledgmentsGroupingTracker : [ConsumerBase{subscription=‘myTopic1_subscriptionName1’, consumerName=‘81946’, topic=‘myTopic1’}] Cannot flush pending acks since we’re not connected to broker
2022-10-24 23:13:39.199 DEBUG 8108 — [r-client-io-1-1] PersistentAcknowledgmentsGroupingTracker : [ConsumerBase{subscription=‘myTopic1_subscriptionName1’, consumerName=‘81946’, topic=‘myTopic1’}] Cannot flush pending acks since we’re not connected to broker
2022-10-24 23:13:39.300 DEBUG 8108 — [r-client-io-1-1] PersistentAcknowledgmentsGroupingTracker : [ConsumerBase{subscription=‘myTopic1_subscriptionName1’, consumerName=‘81946’, topic=‘myTopic1’}] Cannot flush pending acks since we’re not connected to broker
2022-10-24 23:13:39.305 INFO 8108 — [ulsar-timer-6-1] o.a.p.client.impl.ConnectionHandler : [myTopic1] [myTopic1_subscriptionName1] Reconnecting after connection was closed
2022-10-24 23:13:39.402 DEBUG 8108 — [r-client-io-1-1] PersistentAcknowledgmentsGroupingTracker : [ConsumerBase{subscription=‘myTopic1_subscriptionName1’, consumerName=‘81946’, topic=‘myTopic1’}] Cannot flush pending acks since we’re not connected to broker
2022-10-24 23:13:39.504 DEBUG 8108 — [r-client-io-1-1] PersistentAcknowledgmentsGroupingTracker : [ConsumerBase{subscription=‘myTopic1_subscriptionName1’, consumerName=‘81946’, topic=‘myTopic1’}] Cannot flush pending acks since we’re not connected to broker
2022-10-24 23:13:39.554 DEBUG 8108 — [r-client-io-1-1] o.a.p.common.protocol.PulsarDecoder : [/192.168.3.84:6650] Received cmd LOOKUP_RESPONSE
2022-10-24 23:13:39.554 DEBUG 8108 — [r-client-io-1-1] org.apache.pulsar.client.impl.ClientCnx : Received Broker lookup response: 3532537564388470846 Connect
2022-10-24 23:13:39.555 INFO 8108 — [r-client-io-1-1] o.a.pulsar.client.impl.ConsumerImpl : [myTopic1][myTopic1_subscriptionName1] Subscribing to topic on cnx [id: 0x7947367d, L:/192.168.3.188:56314 - R:/192.168.3.84:6650], consumerId 0
2022-10-24 23:13:39.560 DEBUG 8108 — [r-client-io-1-1] o.a.p.common.protocol.PulsarDecoder : [/192.168.3.84:6650] Received cmd SUCCESS
2022-10-24 23:13:39.561 DEBUG 8108 — [r-client-io-1-1] org.apache.pulsar.client.impl.ClientCnx : [id: 0x7947367d, L:/192.168.3.188:56314 - R:/192.168.3.84:6650] Received success response from server: 3532537564388470847
2022-10-24 23:13:39.561 INFO 8108 — [r-client-io-1-1] o.a.pulsar.client.impl.ConsumerImpl : [myTopic1][myTopic1_subscriptionName1] Subscribed to topic on /192.168.3.84:6650 – consumer: 0
2022-10-24 23:13:39.561 DEBUG 8108 — [r-client-io-1-1] o.a.pulsar.client.impl.ConsumerImpl : [myTopic1] [myTopic1_subscriptionName1] Adding 20 additional permits
2022-10-24 23:13:39.561 DEBUG 8108 — [r-client-io-1-1] o.a.pulsar.client.impl.ConsumerImpl : Consumer 0 sent 20 permits to broker
2022-10-24 23:13:39.579 DEBUG 8108 — [r-client-io-1-1] o.a.p.common.protocol.PulsarDecoder : [/192.168.3.84:6650] Received cmd MESSAGE
2022-10-24 23:13:39.579 DEBUG 8108 — [r-client-io-1-1] org.apache.pulsar.client.impl.ClientCnx : [id: 0x7947367d, L:/192.168.3.188:56314 - R:/192.168.3.84:6650] Received a message from the server: org.apache.pulsar.common.api.proto.CommandMessage@2dc6ab01
2022-10-24 23:13:39.580 DEBUG 8108 — [r-client-io-1-1] o.a.pulsar.client.impl.ConsumerImpl : [myTopic1][myTopic1_subscriptionName1] Received message: 3611/5
2022-10-24 23:13:39.580 DEBUG 8108 — [r-client-io-1-1] o.a.pulsar.client.impl.ConsumerImpl : [myTopic1_subscriptionName1] [81946] processing message num - 0 in batch
2022-10-24 23:13:39.580 DEBUG 8108 — [r-client-io-1-1] o.a.pulsar.client.impl.ConsumerImpl : [myTopic1_subscriptionName1] [81946] enqueued messages in batch. queue size - 0, available queue size - 2147483647
2022-10-24 23:13:39.580 DEBUG 8108 — [r-client-io-1-1] o.a.p.common.protocol.PulsarDecoder : [/192.168.3.84:6650] Received cmd MESSAGE
2022-10-24 23:13:39.580 DEBUG 8108 — [r-client-io-1-1] org.apache.pulsar.client.impl.ClientCnx : [id: 0x7947367d, L:/192.168.3.188:56314 - R:/192.168.3.84:6650] Received a message from the server: org.apache.pulsar.common.api.proto.CommandMessage@2dc6ab01
2022-10-24 23:13:39.580 DEBUG 8108 — [r-client-io-1-1] o.a.pulsar.client.impl.ConsumerImpl : [myTopic1][myTopic1_subscriptionName1] Received message: 3611/6
2022-10-24 23:13:39.580 DEBUG 8108 — [nt-internal-4-1] o.a.pulsar.client.impl.ConsumerBase : [myTopic1] [myTopic1_subscriptionName1] Message has been cleared from the queue
2022-10-24 23:13:39.580 DEBUG 8108 — [al-listener-3-1] o.a.pulsar.client.impl.ConsumerBase : [myTopic1][myTopic1_subscriptionName1] Calling message listener for message 3611:5:-1:0
2022-10-24 23:13:39.580 DEBUG 8108 — [r-client-io-1-1] o.a.pulsar.client.impl.ConsumerImpl : [myTopic1_subscriptionName1] [81946] processing message num - 0 in batch
2022-10-24 23:13:39.580 DEBUG 8108 — [r-client-io-1-1] o.a.pulsar.client.impl.ConsumerImpl : [myTopic1_subscriptionName1] [81946] enqueued messages in batch. queue size - 0, available queue size - 2147483647
2022-10-24 23:13:39.580 DEBUG 8108 — [nt-internal-4-1] o.a.pulsar.client.impl.ConsumerBase : [myTopic1] [myTopic1_subscriptionName1] Message has been cleared from the queue
2022-10-24 23:13:39.580 DEBUG 8108 — [r-client-io-1-1] o.a.p.common.protocol.PulsarDecoder : [/192.168.3.84:6650] Received cmd MESSAGE
2022-10-24 23:13:39.580 DEBUG 8108 — [r-client-io-1-1] org.apache.pulsar.client.impl.ClientCnx : [id: 0x7947367d, L:/192.168.3.188:56314 - R:/192.168.3.84:6650] Received a message from the server: org.apache.pulsar.common.api.proto.CommandMessage@2dc6ab01
2022-10-24 23:13:39.580 DEBUG 8108 — [r-client-io-1-1] o.a.pulsar.client.impl.ConsumerImpl : [myTopic1][myTopic1_subscriptionName1] Received message: 3611/7
2022-10-24 23:13:39.580 DEBUG 8108 — [r-client-io-1-1] o.a.pulsar.client.impl.ConsumerImpl : [myTopic1_subscriptionName1] [81946] processing message num - 0 in batch
2022-10-24 23:13:39.580 DEBUG 8108 — [r-client-io-1-1] o.a.pulsar.client.impl.ConsumerImpl : [myTopic1_subscriptionName1] [81946] enqueued messages in batch. queue size - 0, available queue size - 2147483647
2022-10-24 23:13:39.580 DEBUG 8108 — [nt-internal-4-1] o.a.pulsar.client.impl.ConsumerBase : [myTopic1] [myTopic1_subscriptionName1] Message has been cleared from the queue
2022-10-24 23:13:39.580 DEBUG 8108 — [r-client-io-1-1] o.a.p.common.protocol.PulsarDecoder : [/192.168.3.84:6650] Received cmd MESSAGE
2022-10-24 23:13:39.580 DEBUG 8108 — [r-client-io-1-1] org.apache.pulsar.client.impl.ClientCnx : [id: 0x7947367d, L:/192.168.3.188:56314 - R:/192.168.3.84:6650] Received a message from the server: org.apache.pulsar.common.api.proto.CommandMessage@2dc6ab01
2022-10-24 23:13:39.580 DEBUG 8108 — [r-client-io-1-1] o.a.pulsar.client.impl.ConsumerImpl : [myTopic1][myTopic1_subscriptionName1] Received message: 3611/8
2022-10-24 23:13:39.580 DEBUG 8108 — [r-client-io-1-1] o.a.pulsar.client.impl.ConsumerImpl : [myTopic1_subscriptionName1] [81946] processing message num - 0 in batch
2022-10-24 23:13:39.581 DEBUG 8108 — [r-client-io-1-1] o.a.pulsar.client.impl.ConsumerImpl : [myTopic1_subscriptionName1] [81946] enqueued messages in batch. queue size - 0, available queue size - 2147483647
2022-10-24 23:13:39.581 DEBUG 8108 — [nt-internal-4-1] o.a.pulsar.client.impl.ConsumerBase : [myTopic1] [myTopic1_subscriptionName1] Message has been cleared from the queue
2022-10-24 23:13:39.581 DEBUG 8108 — [r-client-io-1-1] o.a.p.common.protocol.PulsarDecoder : [/192.168.3.84:6650] Received cmd MESSAGE
2022-10-24 23:13:39.581 DEBUG 8108 — [r-client-io-1-1] org.apache.pulsar.client.impl.ClientCnx : [id: 0x7947367d, L:/192.168.3.188:56314 - R:/192.168.3.84:6650] Received a message from the server: org.apache.pulsar.common.api.proto.CommandMessage@2dc6ab01
2022-10-24 23:13:39.581 DEBUG 8108 — [r-client-io-1-1] o.a.pulsar.client.impl.ConsumerImpl : [myTopic1][myTopic1_subscriptionName1] Received message: 3611/9
2022-10-24 23:13:39.581 DEBUG 8108 — [r-client-io-1-1] o.a.pulsar.client.impl.ConsumerImpl : [myTopic1_subscriptionName1] [81946] processing message num - 0 in batch
2022-10-24 23:13:39.581 DEBUG 8108 — [r-client-io-1-1] o.a.pulsar.client.impl.ConsumerImpl : [myTopic1_subscriptionName1] [81946] enqueued messages in batch. queue size - 0, available queue size - 2147483647
2022-10-24 23:13:39.581 DEBUG 8108 — [nt-internal-4-1] o.a.pulsar.client.impl.ConsumerBase : [myTopic1] [myTopic1_subscriptionName1] Message has been cleared from the queue
2022-10-24 23:13:39.581 DEBUG 8108 — [r-client-io-1-1] o.a.p.common.protocol.PulsarDecoder : [/192.168.3.84:6650] Received cmd MESSAGE
2022-10-24 23:13:39.581 DEBUG 8108 — [r-client-io-1-1] org.apache.pulsar.client.impl.ClientCnx : [id: 0x7947367d, L:/192.168.3.188:56314 - R:/192.168.3.84:6650] Received a message from the server: org.apache.pulsar.common.api.proto.CommandMessage@2dc6ab01
2022-10-24 23:13:39.581 DEBUG 8108 — [r-client-io-1-1] o.a.pulsar.client.impl.ConsumerImpl : [myTopic1][myTopic1_subscriptionName1] Received message: 3611/10
2022-10-24 23:13:39.581 DEBUG 8108 — [r-client-io-1-1] o.a.pulsar.client.impl.ConsumerImpl : [myTopic1_subscriptionName1] [81946] processing message num - 0 in batch
2022-10-24 23:13:39.581 DEBUG 8108 — [r-client-io-1-1] o.a.pulsar.client.impl.ConsumerImpl : [myTopic1_subscriptionName1] [81946] enqueued messages in batch. queue size - 0, available queue size - 2147483647
2022-10-24 23:13:39.581 DEBUG 8108 — [nt-internal-4-1] o.a.pulsar.client.impl.ConsumerBase : [myTopic1] [myTopic1_subscriptionName1] Message has been cleared from the queue
2022-10-24 23:13:39.581 DEBUG 8108 — [r-client-io-1-1] o.a.p.common.protocol.PulsarDecoder : [/192.168.3.84:6650] Received cmd MESSAGE
2022-10-24 23:13:39.581 DEBUG 8108 — [r-client-io-1-1] org.apache.pulsar.client.impl.ClientCnx : [id: 0x7947367d, L:/192.168.3.188:56314 - R:/192.168.3.84:6650] Received a message from the server: org.apache.pulsar.common.api.proto.CommandMessage@2dc6ab01
2022-10-24 23:13:39.581 DEBUG 8108 — [r-client-io-1-1] o.a.pulsar.client.impl.ConsumerImpl : [myTopic1][myTopic1_subscriptionName1] Received message: 3611/11
2022-10-24 23:13:39.581 DEBUG 8108 — [r-client-io-1-1] o.a.pulsar.client.impl.ConsumerImpl : [myTopic1_subscriptionName1] [81946] processing message num - 0 in batch
2022-10-24 23:13:39.581 DEBUG 8108 — [r-client-io-1-1] o.a.pulsar.client.impl.ConsumerImpl : [myTopic1_subscriptionName1] [81946] enqueued messages in batch. queue size - 0, available queue size - 2147483647
2022-10-24 23:13:39.581 DEBUG 8108 — [r-client-io-1-1] o.a.p.common.protocol.PulsarDecoder : [/192.168.3.84:6650] Received cmd MESSAGE
2022-10-24 23:13:39.581 DEBUG 8108 — [nt-internal-4-1] o.a.pulsar.client.impl.ConsumerBase : [myTopic1] [myTopic1_subscriptionName1] Message has been cleared from the queue
2022-10-24 23:13:39.581 DEBUG 8108 — [r-client-io-1-1] org.apache.pulsar.client.impl.ClientCnx : [id: 0x7947367d, L:/192.168.3.188:56314 - R:/192.168.3.84:6650] Received a message from the server: org.apache.pulsar.common.api.proto.CommandMessage@2dc6ab01
2022-10-24 23:13:39.581 DEBUG 8108 — [r-client-io-1-1] o.a.pulsar.client.impl.ConsumerImpl : [myTopic1][myTopic1_subscriptionName1] Received message: 3611/12
2022-10-24 23:13:39.581 DEBUG 8108 — [r-client-io-1-1] o.a.pulsar.client.impl.ConsumerImpl : [myTopic1_subscriptionName1] [81946] processing message num - 0 in batch
2022-10-24 23:13:39.581 DEBUG 8108 — [r-client-io-1-1] o.a.pulsar.client.impl.ConsumerImpl : [myTopic1_subscriptionName1] [81946] enqueued messages in batch. queue size - 0, available queue size - 2147483647
2022-10-24 23:13:39.581 DEBUG 8108 — [nt-internal-4-1] o.a.pulsar.client.impl.ConsumerBase : [myTopic1] [myTopic1_subscriptionName1] Message has been cleared from the queue
2022-10-24 23:13:39.581 DEBUG 8108 — [r-client-io-1-1] o.a.p.common.protocol.PulsarDecoder : [/192.168.3.84:6650] Received cmd MESSAGE
2022-10-24 23:13:39.581 DEBUG 8108 — [r-client-io-1-1] org.apache.pulsar.client.impl.ClientCnx : [id: 0x7947367d, L:/192.168.3.188:56314 - R:/192.168.3.84:6650] Received a message from the server: org.apache.pulsar.common.api.proto.CommandMessage@2dc6ab01
2022-10-24 23:13:39.581 DEBUG 8108 — [r-client-io-1-1] o.a.pulsar.client.impl.ConsumerImpl : [myTopic1][myTopic1_subscriptionName1] Received message: 3611/13
2022-10-24 23:13:39.582 DEBUG 8108 — [r-client-io-1-1] o.a.pulsar.client.impl.ConsumerImpl : [myTopic1_subscriptionName1] [81946] processing message num - 0 in batch
2022-10-24 23:13:39.582 DEBUG 8108 — [r-client-io-1-1] o.a.pulsar.client.impl.ConsumerImpl : [myTopic1_subscriptionName1] [81946] enqueued messages in batch. queue size - 0, available queue size - 2147483647
2022-10-24 23:13:39.582 DEBUG 8108 — [nt-internal-4-1] o.a.pulsar.client.impl.ConsumerBase : [myTopic1] [myTopic1_subscriptionName1] Message has been cleared from the queue
2022-10-24 23:13:39.582 DEBUG 8108 — [r-client-io-1-1] o.a.p.common.protocol.PulsarDecoder : [/192.168.3.84:6650] Received cmd MESSAGE
2022-10-24 23:13:39.582 DEBUG 8108 — [r-client-io-1-1] org.apache.pulsar.client.impl.ClientCnx : [id: 0x7947367d, L:/192.168.3.188:56314 - R:/192.168.3.84:6650] Received a message from the server: org.apache.pulsar.common.api.proto.CommandMessage@2dc6ab01
2022-10-24 23:13:39.582 DEBUG 8108 — [r-client-io-1-1] o.a.pulsar.client.impl.ConsumerImpl : [myTopic1][myTopic1_subscriptionName1] Received message: 3611/14
2022-10-24 23:13:39.582 DEBUG 8108 — [r-client-io-1-1] o.a.pulsar.client.impl.ConsumerImpl : [myTopic1_subscriptionName1] [81946] processing message num - 0 in batch
2022-10-24 23:13:39.582 DEBUG 8108 — [r-client-io-1-1] o.a.pulsar.client.impl.ConsumerImpl : [myTopic1_subscriptionName1] [81946] enqueued messages in batch. queue size - 0, available queue size - 2147483647
2022-10-24 23:13:39.582 DEBUG 8108 — [nt-internal-4-1] o.a.pulsar.client.impl.ConsumerBase : [myTopic1] [myTopic1_subscriptionName1] Message has been cleared from the queue
2022-10-24 23:13:39.582 DEBUG 8108 — [r-client-io-1-1] o.a.p.common.protocol.PulsarDecoder : [/192.168.3.84:6650] Received cmd MESSAGE
2022-10-24 23:13:39.582 DEBUG 8108 — [r-client-io-1-1] org.apache.pulsar.client.impl.ClientCnx : [id: 0x7947367d, L:/192.168.3.188:56314 - R:/192.168.3.84:6650] Received a message from the server: org.apache.pulsar.common.api.proto.CommandMessage@2dc6ab01
2022-10-24 23:13:39.582 DEBUG 8108 — [r-client-io-1-1] o.a.pulsar.client.impl.ConsumerImpl : [myTopic1][myTopic1_subscriptionName1] Received message: 3611/15
2022-10-24 23:13:39.582 DEBUG 8108 — [r-client-io-1-1] o.a.pulsar.client.impl.ConsumerImpl : [myTopic1] [myTopic1_subscriptionName1] Ignoring message as it was already being acked earlier by same consumer 81946/3611:15:-1
2022-10-24 23:13:39.582 DEBUG 8108 — [r-client-io-1-1] o.a.p.common.protocol.PulsarDecoder : [/192.168.3.84:6650] Received cmd MESSAGE
2022-10-24 23:13:39.582 DEBUG 8108 — [r-client-io-1-1] org.apache.pulsar.client.impl.ClientCnx : [id: 0x7947367d, L:/192.168.3.188:56314 - R:/192.168.3.84:6650] Received a message from the server: org.apache.pulsar.common.api.proto.CommandMessage@2dc6ab01
2022-10-24 23:13:39.582 DEBUG 8108 — [r-client-io-1-1] o.a.pulsar.client.impl.ConsumerImpl : [myTopic1][myTopic1_subscriptionName1] Received message: 3611/16
2022-10-24 23:13:39.582 DEBUG 8108 — [r-client-io-1-1] o.a.pulsar.client.impl.ConsumerImpl : [myTopic1] [myTopic1_subscriptionName1] Ignoring message as it was already being acked earlier by same consumer 81946/3611:16:-1
2022-10-24 23:13:39.582 DEBUG 8108 — [r-client-io-1-1] o.a.p.common.protocol.PulsarDecoder : [/192.168.3.84:6650] Received cmd MESSAGE
2022-10-24 23:13:39.582 DEBUG 8108 — [r-client-io-1-1] org.apache.pulsar.client.impl.ClientCnx : [id: 0x7947367d, L:/192.168.3.188:56314 - R:/192.168.3.84:6650] Received a message from the server: org.apache.pulsar.common.api.proto.CommandMessage@2dc6ab01
2022-10-24 23:13:39.582 DEBUG 8108 — [r-client-io-1-1] o.a.pulsar.client.impl.ConsumerImpl : [myTopic1][myTopic1_subscriptionName1] Received message: 3611/17
2022-10-24 23:13:39.582 DEBUG 8108 — [r-client-io-1-1] o.a.pulsar.client.impl.ConsumerImpl : [myTopic1] [myTopic1_subscriptionName1] Ignoring message as it was already being acked earlier by same consumer 81946/3611:17:-1
2022-10-24 23:13:39.582 DEBUG 8108 — [r-client-io-1-1] o.a.p.common.protocol.PulsarDecoder : [/192.168.3.84:6650] Received cmd MESSAGE
2022-10-24 23:13:39.583 DEBUG 8108 — [r-client-io-1-1] org.apache.pulsar.client.impl.ClientCnx : [id: 0x7947367d, L:/192.168.3.188:56314 - R:/192.168.3.84:6650] Received a message from the server: org.apache.pulsar.common.api.proto.CommandMessage@2dc6ab01
2022-10-24 23:13:39.583 DEBUG 8108 — [r-client-io-1-1] o.a.pulsar.client.impl.ConsumerImpl : [myTopic1][myTopic1_subscriptionName1] Received message: 3611/18
2022-10-24 23:13:39.583 DEBUG 8108 — [r-client-io-1-1] o.a.pulsar.client.impl.ConsumerImpl : [myTopic1] [myTopic1_subscriptionName1] Ignoring message as it was already being acked earlier by same consumer 81946/3611:18:-1
2022-10-24 23:13:39.583 DEBUG 8108 — [r-client-io-1-1] o.a.p.common.protocol.PulsarDecoder : [/192.168.3.84:6650] Received cmd MESSAGE
2022-10-24 23:13:39.583 DEBUG 8108 — [r-client-io-1-1] org.apache.pulsar.client.impl.ClientCnx : [id: 0x7947367d, L:/192.168.3.188:56314 - R:/192.168.3.84:6650] Received a message from the server: org.apache.pulsar.common.api.proto.CommandMessage@2dc6ab01
2022-10-24 23:13:39.583 DEBUG 8108 — [r-client-io-1-1] o.a.pulsar.client.impl.ConsumerImpl : [myTopic1][myTopic1_subscriptionName1] Received message: 3611/19
2022-10-24 23:13:39.583 DEBUG 8108 — [r-client-io-1-1] o.a.pulsar.client.impl.ConsumerImpl : [myTopic1] [myTopic1_subscriptionName1] Ignoring message as it was already being acked earlier by same consumer 81946/3611:19:-1
2022-10-24 23:13:39.583 DEBUG 8108 — [r-client-io-1-1] o.a.p.common.protocol.PulsarDecoder : [/192.168.3.84:6650] Received cmd MESSAGE
2022-10-24 23:13:39.583 DEBUG 8108 — [r-client-io-1-1] org.apache.pulsar.client.impl.ClientCnx : [id: 0x7947367d, L:/192.168.3.188:56314 - R:/192.168.3.84:6650] Received a message from the server: org.apache.pulsar.common.api.proto.CommandMessage@2dc6ab01
2022-10-24 23:13:39.583 DEBUG 8108 — [r-client-io-1-1] o.a.pulsar.client.impl.ConsumerImpl : [myTopic1][myTopic1_subscriptionName1] Received message: 3611/20
2022-10-24 23:13:39.583 DEBUG 8108 — [r-client-io-1-1] o.a.pulsar.client.impl.ConsumerImpl : [myTopic1_subscriptionName1] [81946] processing message num - 0 in batch
2022-10-24 23:13:39.583 DEBUG 8108 — [r-client-io-1-1] o.a.pulsar.client.impl.ConsumerImpl : [myTopic1_subscriptionName1] [81946] enqueued messages in batch. queue size - 0, available queue size - 2147483647
2022-10-24 23:13:39.583 DEBUG 8108 — [r-client-io-1-1] o.a.p.common.protocol.PulsarDecoder : [/192.168.3.84:6650] Received cmd MESSAGE
2022-10-24 23:13:39.583 DEBUG 8108 — [nt-internal-4-1] o.a.pulsar.client.impl.ConsumerBase : [myTopic1] [myTopic1_subscriptionName1] Message has been cleared from the queue
2022-10-24 23:13:39.583 DEBUG 8108 — [r-client-io-1-1] org.apache.pulsar.client.impl.ClientCnx : [id: 0x7947367d, L:/192.168.3.188:56314 - R:/192.168.3.84:6650] Received a message from the server: org.apache.pulsar.common.api.proto.CommandMessage@2dc6ab01
2022-10-24 23:13:39.583 DEBUG 8108 — [r-client-io-1-1] o.a.pulsar.client.impl.ConsumerImpl : [myTopic1][myTopic1_subscriptionName1] Received message: 3611/21
2022-10-24 23:13:39.583 DEBUG 8108 — [r-client-io-1-1] o.a.pulsar.client.impl.ConsumerImpl : [myTopic1_subscriptionName1] [81946] processing message num - 0 in batch
2022-10-24 23:13:39.583 DEBUG 8108 — [r-client-io-1-1] o.a.pulsar.client.impl.ConsumerImpl : [myTopic1_subscriptionName1] [81946] enqueued messages in batch. queue size - 0, available queue size - 2147483647
2022-10-24 23:13:39.583 DEBUG 8108 — [nt-internal-4-1] o.a.pulsar.client.impl.ConsumerBase : [myTopic1] [myTopic1_subscriptionName1] Message has been cleared from the queue
2022-10-24 23:13:39.583 DEBUG 8108 — [r-client-io-1-1] o.a.p.common.protocol.PulsarDecoder : [/192.168.3.84:6650] Received cmd MESSAGE
2022-10-24 23:13:39.583 DEBUG 8108 — [r-client-io-1-1] org.apache.pulsar.client.impl.ClientCnx : [id: 0x7947367d, L:/192.168.3.188:56314 - R:/192.168.3.84:6650] Received a message from the server: org.apache.pulsar.common.api.proto.CommandMessage@2dc6ab01
2022-10-24 23:13:39.583 DEBUG 8108 — [r-client-io-1-1] o.a.pulsar.client.impl.ConsumerImpl : [myTopic1][myTopic1_subscriptionName1] Received message: 3611/22
2022-10-24 23:13:39.583 DEBUG 8108 — [r-client-io-1-1] o.a.pulsar.client.impl.ConsumerImpl : [myTopic1_subscriptionName1] [81946] processing message num - 0 in batch
2022-10-24 23:13:39.583 DEBUG 8108 — [r-client-io-1-1] o.a.pulsar.client.impl.ConsumerImpl : [myTopic1_subscriptionName1] [81946] enqueued messages in batch. queue size - 0, available queue size - 2147483647
2022-10-24 23:13:39.583 DEBUG 8108 — [r-client-io-1-1] o.a.p.common.protocol.PulsarDecoder : [/192.168.3.84:6650] Received cmd MESSAGE
2022-10-24 23:13:39.583 DEBUG 8108 — [nt-internal-4-1] o.a.pulsar.client.impl.ConsumerBase : [myTopic1] [myTopic1_subscriptionName1] Message has been cleared from the queue
2022-10-24 23:13:39.583 DEBUG 8108 — [r-client-io-1-1] org.apache.pulsar.client.impl.ClientCnx : [id: 0x7947367d, L:/192.168.3.188:56314 - R:/192.168.3.84:6650] Received a message from the server: org.apache.pulsar.common.api.proto.CommandMessage@2dc6ab01
2022-10-24 23:13:39.583 DEBUG 8108 — [r-client-io-1-1] o.a.pulsar.client.impl.ConsumerImpl : [myTopic1][myTopic1_subscriptionName1] Received message: 3611/23
2022-10-24 23:13:39.583 DEBUG 8108 — [r-client-io-1-1] o.a.pulsar.client.impl.ConsumerImpl : [myTopic1_subscriptionName1] [81946] processing message num - 0 in batch
2022-10-24 23:13:39.583 DEBUG 8108 — [r-client-io-1-1] o.a.pulsar.client.impl.ConsumerImpl : [myTopic1_subscriptionName1] [81946] enqueued messages in batch. queue size - 0, available queue size - 2147483647
2022-10-24 23:13:39.583 DEBUG 8108 — [nt-internal-4-1] o.a.pulsar.client.impl.ConsumerBase : [myTopic1] [myTopic1_subscriptionName1] Message has been cleared from the queue
2022-10-24 23:13:39.583 DEBUG 8108 — [r-client-io-1-1] o.a.p.common.protocol.PulsarDecoder : [/192.168.3.84:6650] Received cmd MESSAGE
2022-10-24 23:13:39.583 DEBUG 8108 — [r-client-io-1-1] org.apache.pulsar.client.impl.ClientCnx : [id: 0x7947367d, L:/192.168.3.188:56314 - R:/192.168.3.84:6650] Received a message from the server: org.apache.pulsar.common.api.proto.CommandMessage@2dc6ab01
2022-10-24 23:13:39.583 DEBUG 8108 — [r-client-io-1-1] o.a.pulsar.client.impl.ConsumerImpl : [myTopic1][myTopic1_subscriptionName1] Received message: 3611/24
2022-10-24 23:13:39.583 DEBUG 8108 — [r-client-io-1-1] o.a.pulsar.client.impl.ConsumerImpl : [myTopic1_subscriptionName1] [81946] processing message num - 0 in batch
2022-10-24 23:13:39.583 DEBUG 8108 — [r-client-io-1-1] o.a.pulsar.client.impl.ConsumerImpl : [myTopic1_subscriptionName1] [81946] enqueued messages in batch. queue size - 0, available queue size - 2147483647
2022-10-24 23:13:39.583 DEBUG 8108 — [nt-internal-4-1] o.a.pulsar.client.impl.ConsumerBase : [myTopic1] [myTopic1_subscriptionName1] Message has been cleared from the queue
2022-10-24 23:13:39.606 DEBUG 8108 — [r-client-io-1-1] PersistentAcknowledgmentsGroupingTracker : [ConsumerBase{subscription=‘myTopic1_subscriptionName1’, consumerName=‘81946’, topic=‘myTopic1’}] Flushing pending acks to broker: last-cumulative-ack: -1:-1:-1 – individual-acks: – individual-batch-index-acks: [(3611,5,null), (3611,15,null), (3611,16,null), (3611,17,null), (3611,18,null), (3611,19,null)]
对消息:我是消息6,执行了ACK确认操作
2022-10-24 23:13:41.580 DEBUG 8108 — [al-listener-3-1] o.a.pulsar.client.impl.ConsumerBase : [myTopic1][myTopic1_subscriptionName1] Calling message listener for message 3611:6:-1:0
2022-10-24 23:13:41.625 DEBUG 8108 — [r-client-io-1-1] PersistentAcknowledgmentsGroupingTracker : [ConsumerBase{subscription=‘myTopic1_subscriptionName1’, consumerName=‘81946’, topic=‘myTopic1’}] Flushing pending acks to broker: last-cumulative-ack: -1:-1:-1 – individual-acks: – individual-batch-index-acks: [(3611,6,null)]

对消息:我是消息7,执行了ACK确认操作
2022-10-24 23:13:43.580 DEBUG 8108 — [al-listener-3-1] o.a.pulsar.client.impl.ConsumerBase : [myTopic1][myTopic1_subscriptionName1] Calling message listener for message 3611:7:-1:0
2022-10-24 23:13:43.644 DEBUG 8108 — [r-client-io-1-1] PersistentAcknowledgmentsGroupingTracker : [ConsumerBase{subscription=‘myTopic1_subscriptionName1’, consumerName=‘81946’, topic=‘myTopic1’}] Flushing pending acks to broker: last-cumulative-ack: -1:-1:-1 – individual-acks: – individual-batch-index-acks: [(3611,7,null)]
2022-10-24 23:13:45.164 DEBUG 8108 — [alina-utility-2] org.apache.catalina.session.ManagerBase : Start expire sessions StandardManager at 1666624425164 sessioncount 0
2022-10-24 23:13:45.164 DEBUG 8108 — [alina-utility-2] org.apache.catalina.session.ManagerBase : End expire sessions StandardManager processingTime 0 expired sessions: 0
对消息:我是消息8,执行了ACK确认操作
2022-10-24 23:13:45.581 DEBUG 8108 — [al-listener-3-1] o.a.pulsar.client.impl.ConsumerBase : [myTopic1][myTopic1_subscriptionName1] Calling message listener for message 3611:8:-1:0
2022-10-24 23:13:45.666 DEBUG 8108 — [r-client-io-1-1] PersistentAcknowledgmentsGroupingTracker : [ConsumerBase{subscription=‘myTopic1_subscriptionName1’, consumerName=‘81946’, topic=‘myTopic1’}] Flushing pending acks to broker: last-cumulative-ack: -1:-1:-1 – individual-acks: – individual-batch-index-acks: [(3611,8,null)]
对消息:我是消息9,执行了ACK确认操作
2022-10-24 23:13:47.581 DEBUG 8108 — [al-listener-3-1] o.a.pulsar.client.impl.ConsumerBase : [myTopic1][myTopic1_subscriptionName1] Calling message listener for message 3611:9:-1:0
2022-10-24 23:13:47.581 DEBUG 8108 — [al-listener-3-1] o.a.pulsar.client.impl.ConsumerImpl : [myTopic1] [myTopic1_subscriptionName1] Adding 10 additional permits
2022-10-24 23:13:47.581 DEBUG 8108 — [r-client-io-1-1] o.a.pulsar.client.impl.ConsumerImpl : Consumer 0 sent 10 permits to broker
2022-10-24 23:13:47.586 DEBUG 8108 — [r-client-io-1-1] PersistentAcknowledgmentsGroupingTracker : [ConsumerBase{subscription=‘myTopic1_subscriptionName1’, consumerName=‘81946’, topic=‘myTopic1’}] Flushing pending acks to broker: last-cumulative-ack: -1:-1:-1 – individual-acks: – individual-batch-index-acks: [(3611,9,null)]
2022-10-24 23:13:47.749 DEBUG 8108 — [r-client-io-1-1] o.a.p.common.protocol.PulsarDecoder : [/192.168.3.84:6650] Received cmd MESSAGE
2022-10-24 23:13:47.749 DEBUG 8108 — [r-client-io-1-1] org.apache.pulsar.client.impl.ClientCnx : [id: 0x7947367d, L:/192.168.3.188:56314 - R:/192.168.3.84:6650] Received a message from the server: org.apache.pulsar.common.api.proto.CommandMessage@2dc6ab01
2022-10-24 23:13:47.749 DEBUG 8108 — [r-client-io-1-1] o.a.pulsar.client.impl.ConsumerImpl : [myTopic1][myTopic1_subscriptionName1] Received message: 3611/25
2022-10-24 23:13:47.749 DEBUG 8108 — [r-client-io-1-1] o.a.pulsar.client.impl.ConsumerImpl : [myTopic1_subscriptionName1] [81946] processing message num - 0 in batch
2022-10-24 23:13:47.749 DEBUG 8108 — [r-client-io-1-1] o.a.pulsar.client.impl.ConsumerImpl : [myTopic1_subscriptionName1] [81946] enqueued messages in batch. queue size - 0, available queue size - 2147483647
2022-10-24 23:13:47.749 DEBUG 8108 — [r-client-io-1-1] o.a.p.common.protocol.PulsarDecoder : [/192.168.3.84:6650] Received cmd MESSAGE
2022-10-24 23:13:47.749 DEBUG 8108 — [r-client-io-1-1] org.apache.pulsar.client.impl.ClientCnx : [id: 0x7947367d, L:/192.168.3.188:56314 - R:/192.168.3.84:6650] Received a message from the server: org.apache.pulsar.common.api.proto.CommandMessage@2dc6ab01
2022-10-24 23:13:47.749 DEBUG 8108 — [r-client-io-1-1] o.a.pulsar.client.impl.ConsumerImpl : [myTopic1][myTopic1_subscriptionName1] Received message: 3611/26
2022-10-24 23:13:47.749 DEBUG 8108 — [nt-internal-4-1] o.a.pulsar.client.impl.ConsumerBase : [myTopic1] [myTopic1_subscriptionName1] Message has been cleared from the queue
2022-10-24 23:13:47.749 DEBUG 8108 — [r-client-io-1-1] o.a.pulsar.client.impl.ConsumerImpl : [myTopic1_subscriptionName1] [81946] processing message num - 0 in batch
2022-10-24 23:13:47.750 DEBUG 8108 — [r-client-io-1-1] o.a.pulsar.client.impl.ConsumerImpl : [myTopic1_subscriptionName1] [81946] enqueued messages in batch. queue size - 0, available queue size - 2147483647
2022-10-24 23:13:47.750 DEBUG 8108 — [r-client-io-1-1] o.a.p.common.protocol.PulsarDecoder : [/192.168.3.84:6650] Received cmd MESSAGE
2022-10-24 23:13:47.750 DEBUG 8108 — [nt-internal-4-1] o.a.pulsar.client.impl.ConsumerBase : [myTopic1] [myTopic1_subscriptionName1] Message has been cleared from the queue
2022-10-24 23:13:47.750 DEBUG 8108 — [r-client-io-1-1] org.apache.pulsar.client.impl.ClientCnx : [id: 0x7947367d, L:/192.168.3.188:56314 - R:/192.168.3.84:6650] Received a message from the server: org.apache.pulsar.common.api.proto.CommandMessage@2dc6ab01
2022-10-24 23:13:47.750 DEBUG 8108 — [r-client-io-1-1] o.a.pulsar.client.impl.ConsumerImpl : [myTopic1][myTopic1_subscriptionName1] Received message: 3611/27
2022-10-24 23:13:47.750 DEBUG 8108 — [r-client-io-1-1] o.a.pulsar.client.impl.ConsumerImpl : [myTopic1_subscriptionName1] [81946] processing message num - 0 in batch
2022-10-24 23:13:47.750 DEBUG 8108 — [r-client-io-1-1] o.a.pulsar.client.impl.ConsumerImpl : [myTopic1_subscriptionName1] [81946] enqueued messages in batch. queue size - 0, available queue size - 2147483647
2022-10-24 23:13:47.750 DEBUG 8108 — [r-client-io-1-1] o.a.p.common.protocol.PulsarDecoder : [/192.168.3.84:6650] Received cmd MESSAGE
2022-10-24 23:13:47.750 DEBUG 8108 — [r-client-io-1-1] org.apache.pulsar.client.impl.ClientCnx : [id: 0x7947367d, L:/192.168.3.188:56314 - R:/192.168.3.84:6650] Received a message from the server: org.apache.pulsar.common.api.proto.CommandMessage@2dc6ab01
2022-10-24 23:13:47.750 DEBUG 8108 — [r-client-io-1-1] o.a.pulsar.client.impl.ConsumerImpl : [myTopic1][myTopic1_subscriptionName1] Received message: 3611/28
2022-10-24 23:13:47.750 DEBUG 8108 — [nt-internal-4-1] o.a.pulsar.client.impl.ConsumerBase : [myTopic1] [myTopic1_subscriptionName1] Message has been cleared from the queue
2022-10-24 23:13:47.750 DEBUG 8108 — [r-client-io-1-1] o.a.pulsar.client.impl.ConsumerImpl : [myTopic1_subscriptionName1] [81946] processing message num - 0 in batch
2022-10-24 23:13:47.750 DEBUG 8108 — [r-client-io-1-1] o.a.pulsar.client.impl.ConsumerImpl : [myTopic1_subscriptionName1] [81946] enqueued messages in batch. queue size - 0, available queue size - 2147483647
2022-10-24 23:13:47.750 DEBUG 8108 — [r-client-io-1-1] o.a.p.common.protocol.PulsarDecoder : [/192.168.3.84:6650] Received cmd MESSAGE
2022-10-24 23:13:47.750 DEBUG 8108 — [r-client-io-1-1] org.apache.pulsar.client.impl.ClientCnx : [id: 0x7947367d, L:/192.168.3.188:56314 - R:/192.168.3.84:6650] Received a message from the server: org.apache.pulsar.common.api.proto.CommandMessage@2dc6ab01
2022-10-24 23:13:47.750 DEBUG 8108 — [r-client-io-1-1] o.a.pulsar.client.impl.ConsumerImpl : [myTopic1][myTopic1_subscriptionName1] Received message: 3611/29
2022-10-24 23:13:47.750 DEBUG 8108 — [nt-internal-4-1] o.a.pulsar.client.impl.ConsumerBase : [myTopic1] [myTopic1_subscriptionName1] Message has been cleared from the queue
2022-10-24 23:13:47.750 DEBUG 8108 — [r-client-io-1-1] o.a.pulsar.client.impl.ConsumerImpl : [myTopic1_subscriptionName1] [81946] processing message num - 0 in batch
2022-10-24 23:13:47.750 DEBUG 8108 — [r-client-io-1-1] o.a.pulsar.client.impl.ConsumerImpl : [myTopic1_subscriptionName1] [81946] enqueued messages in batch. queue size - 0, available queue size - 2147483647
2022-10-24 23:13:47.750 DEBUG 8108 — [nt-internal-4-1] o.a.pulsar.client.impl.ConsumerBase : [myTopic1] [myTopic1_subscriptionName1] Message has been cleared from the queue
2022-10-24 23:13:48.020 INFO 8108 — [ulsar-timer-6-1] o.a.p.c.impl.ConsumerStatsRecorderImpl : [myTopic1] [myTopic1_subscriptionName1] [81946] Prefetched messages: 0 — Consume throughput received: 0.33 msgs/s — 0.00 Mbit/s — Ack sent rate: 0.08 ack/s — Failed messages: 0 — batch messages: 0 —Failed acks: 0
对消息:我是消息10,执行了ACK确认操作
2022-10-24 23:13:49.582 DEBUG 8108 — [al-listener-3-1] o.a.pulsar.client.impl.ConsumerBase : [myTopic1][myTopic1_subscriptionName1] Calling message listener for message 3611:10:-1:0
2022-10-24 23:13:49.603 DEBUG 8108 — [r-client-io-1-1] PersistentAcknowledgmentsGroupingTracker : [ConsumerBase{subscription=‘myTopic1_subscriptionName1’, consumerName=‘81946’, topic=‘myTopic1’}] Flushing pending acks to broker: last-cumulative-ack: -1:-1:-1 – individual-acks: – individual-batch-index-acks: [(3611,10,null)]
对消息:我是消息11,执行了ACK确认操作
2022-10-24 23:13:51.583 DEBUG 8108 — [al-listener-3-1] o.a.pulsar.client.impl.ConsumerBase : [myTopic1][myTopic1_subscriptionName1] Calling message listener for message 3611:11:-1:0
2022-10-24 23:13:51.624 DEBUG 8108 — [r-client-io-1-1] PersistentAcknowledgmentsGroupingTracker : [ConsumerBase{subscription=‘myTopic1_subscriptionName1’, consumerName=‘81946’, topic=‘myTopic1’}] Flushing pending acks to broker: last-cumulative-ack: -1:-1:-1 – individual-acks: – individual-batch-index-acks: [(3611,11,null)]
对消息:我是消息12,执行了ACK确认操作
2022-10-24 23:13:53.583 DEBUG 8108 — [al-listener-3-1] o.a.pulsar.client.impl.ConsumerBase : [myTopic1][myTopic1_subscriptionName1] Calling message listener for message 3611:12:-1:0
2022-10-24 23:13:53.646 DEBUG 8108 — [r-client-io-1-1] PersistentAcknowledgmentsGroupingTracker : [ConsumerBase{subscription=‘myTopic1_subscriptionName1’, consumerName=‘81946’, topic=‘myTopic1’}] Flushing pending acks to broker: last-cumulative-ack: -1:-1:-1 – individual-acks: – individual-batch-index-acks: [(3611,12,null)]
对消息:我是消息13,执行了ACK确认操作
2022-10-24 23:13:55.583 DEBUG 8108 — [al-listener-3-1] o.a.pulsar.client.impl.ConsumerBase : [myTopic1][myTopic1_subscriptionName1] Calling message listener for message 3611:13:-1:0
2022-10-24 23:13:55.668 DEBUG 8108 — [r-client-io-1-1] PersistentAcknowledgmentsGroupingTracker : [ConsumerBase{subscription=‘myTopic1_subscriptionName1’, consumerName=‘81946’, topic=‘myTopic1’}] Flushing pending acks to broker: last-cumulative-ack: -1:-1:-1 – individual-acks: – individual-batch-index-acks: [(3611,13,null)]
对消息:我是消息14,执行了ACK确认操作
2022-10-24 23:13:57.584 DEBUG 8108 — [al-listener-3-1] o.a.pulsar.client.impl.ConsumerBase : [myTopic1][myTopic1_subscriptionName1] Calling message listener for message 3611:14:-1:0
2022-10-24 23:13:57.589 DEBUG 8108 — [r-client-io-1-1] PersistentAcknowledgmentsGroupingTracker : [ConsumerBase{subscription=‘myTopic1_subscriptionName1’, consumerName=‘81946’, topic=‘myTopic1’}] Flushing pending acks to broker: last-cumulative-ack: -1:-1:-1 – individual-acks: – individual-batch-index-acks: [(3611,14,null)]
对消息:我是消息15,执行了ACK确认操作
2022-10-24 23:13:59.585 DEBUG 8108 — [al-listener-3-1] o.a.pulsar.client.impl.ConsumerBase : [myTopic1][myTopic1_subscriptionName1] Calling message listener for message 3611:20:-1:0
2022-10-24 23:13:59.613 DEBUG 8108 — [r-client-io-1-1] PersistentAcknowledgmentsGroupingTracker : [ConsumerBase{subscription=‘myTopic1_subscriptionName1’, consumerName=‘81946’, topic=‘myTopic1’}] Flushing pending acks to broker: last-cumulative-ack: -1:-1:-1 – individual-acks: – individual-batch-index-acks: [(3611,20,null)]
对消息:我是消息21,执行了ACK确认操作
2022-10-24 23:14:01.585 DEBUG 8108 — [al-listener-3-1] o.a.pulsar.client.impl.ConsumerBase : [myTopic1][myTopic1_subscriptionName1] Calling message listener for message 3611:21:-1:0
2022-10-24 23:14:01.635 DEBUG 8108 — [r-client-io-1-1] PersistentAcknowledgmentsGroupingTracker : [ConsumerBase{subscription=‘myTopic1_subscriptionName1’, consumerName=‘81946’, topic=‘myTopic1’}] Flushing pending acks to broker: last-cumulative-ack: -1:-1:-1 – individual-acks: – individual-batch-index-acks: [(3611,21,null)]
对消息:我是消息22,执行了ACK确认操作
2022-10-24 23:14:03.586 DEBUG 8108 — [al-listener-3-1] o.a.pulsar.client.impl.ConsumerBase : [myTopic1][myTopic1_subscriptionName1] Calling message listener for message 3611:22:-1:0
2022-10-24 23:14:03.662 DEBUG 8108 — [r-client-io-1-1] PersistentAcknowledgmentsGroupingTracker : [ConsumerBase{subscription=‘myTopic1_subscriptionName1’, consumerName=‘81946’, topic=‘myTopic1’}] Flushing pending acks to broker: last-cumulative-ack: -1:-1:-1 – individual-acks: – individual-batch-index-acks: [(3611,22,null)]
对消息:我是消息23,执行了ACK确认操作
2022-10-24 23:14:05.586 DEBUG 8108 — [al-listener-3-1] o.a.pulsar.client.impl.ConsumerBase : [myTopic1][myTopic1_subscriptionName1] Calling message listener for message 3611:23:-1:0
2022-10-24 23:14:05.685 DEBUG 8108 — [r-client-io-1-1] PersistentAcknowledgmentsGroupingTracker : [ConsumerBase{subscription=‘myTopic1_subscriptionName1’, consumerName=‘81946’, topic=‘myTopic1’}] Flushing pending acks to broker: last-cumulative-ack: -1:-1:-1 – individual-acks: – individual-batch-index-acks: [(3611,23,null)]

这是网络恢复后丢消失的日志,不知道什么原因,感谢。
log分开发的,因为太多了。