fix: add sentAt when put item into pendingQueue (#509)

Signed-off-by: jonyhy96 <hy352144278@gmail.com> Signed-off-by: jonyhy96 hy352144278@gmail.com Fixes #508
apache · Apr 15, 2021 · b4ec53c · b4ec53c
1 parent f17deac
commit b4ec53c
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/pulsar/producer_partition.go b/pulsar/producer_partition.go
@@ -547,6 +547,7 @@ func (p *partitionProducer) internalFlushCurrentBatches() {
 			continue
 		}
 		p.pendingQueue.Put(&pendingItem{
+			sentAt:       time.Now(),
 			batchData:    batchesData[i],
 			sequenceID:   sequenceIDs[i],
 			sendRequests: callbacks[i],