You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pulsar.apache.org by rx...@apache.org on 2020/05/23 08:11:47 UTC

[pulsar-client-go] branch master updated: skip debug print out when batch disabled with no messages (#261)

This is an automated email from the ASF dual-hosted git repository.

rxl pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/pulsar-client-go.git


The following commit(s) were added to refs/heads/master by this push:
     new e31d474  skip debug print out when batch disabled with no messages (#261)
e31d474 is described below

commit e31d474c5d25f13cfdc69596e1c58a2a9e7d5fb7
Author: Ming <it...@gmail.com>
AuthorDate: Sat May 23 04:11:40 2020 -0400

    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 d9990b1..80d8a00 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))