From e31d474c5d25f13cfdc69596e1c58a2a9e7d5fb7 Mon Sep 17 00:00:00 2001 From: Ming Date: Sat, 23 May 2020 04:11:40 -0400 Subject: [PATCH] skip debug print out when batch disabled with no messages (#261) - skip debug print out when batch disabled with no messages --- pulsar/internal/batch_builder.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/pulsar/internal/batch_builder.go b/pulsar/internal/batch_builder.go index d9990b1de9..80d8a001fc 100644 --- a/pulsar/internal/batch_builder.go +++ b/pulsar/internal/batch_builder.go @@ -149,11 +149,11 @@ func (bb *BatchBuilder) reset() { // Flush all the messages buffered in the client and wait until all messages have been successfully persisted. func (bb *BatchBuilder) Flush() (batchData []byte, sequenceID uint64, callbacks []interface{}) { - log.Debug("BatchBuilder flush: messages: ", bb.numMessages) if bb.numMessages == 0 { // No-Op for empty batch return nil, 0, nil } + log.Debug("BatchBuilder flush: messages: ", bb.numMessages) bb.msgMetadata.NumMessagesInBatch = proto.Int32(int32(bb.numMessages)) bb.cmdSend.Send.NumMessages = proto.Int32(int32(bb.numMessages))