sometimes broker send messages to consumer,but consumer can not receive

[leizhiyuan]

we use pulsar client 2.7.4 and use batchReceive() to receive messages. we add a tracer in broker, after we invoke ctx.write(new Message), and flush ,we will write a tracer record (so we can judge we send the message to consumer).

PulsarCommandSenderImpl.java

but sometimes ,we can see there will have an unacked message, but from consumer, once we receive a message, we will print a log, it seems we can not receive this message sometimes.

do you have any idea for this issue? thanks for any idea.

[leizhiyuan]

   Future<Void> writeAndFlushPromise =
                cnx.getCommandSender().sendMessagesToConsumer(consumerId, topicName, subscription, partitionIdx,
                        entries, batchSizes, batchIndexesAcks, redeliveryTracker, epoch);
        writeAndFlushPromise.addListener(status -> {
            // only increment counters after the messages have been successfully written to the TCP/IP connection
            if (status.isSuccess()) {
                msgOut.recordMultipleEvents(totalMessages, totalBytes);
                msgOutCounter.add(totalMessages);
                bytesOutCounter.add(totalBytes);
                chunkedMessageRate.recordMultipleEvents(totalChunkedMessages, 0);
            }
        });

maybe this write fail