Skip to content

Commit

Permalink
skip debug print out when batch disabled with no messages (#261)
Browse files Browse the repository at this point in the history
- skip debug print out when batch disabled with no messages
  • Loading branch information
zzzming authored May 23, 2020
1 parent 416c5f6 commit e31d474
Showing 1 changed file with 1 addition and 1 deletion.
2 changes: 1 addition & 1 deletion pulsar/internal/batch_builder.go
Original file line number Diff line number Diff line change
Expand Up @@ -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))
Expand Down

0 comments on commit e31d474

Please sign in to comment.