diff --git a/pulsar/producer_partition.go b/pulsar/producer_partition.go
index 87c97ed593..b365f83995 100644
--- 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],