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))