From 14eb6c7af9c22b429ac11f47e6f094acc7cd60e7 Mon Sep 17 00:00:00 2001
From: jonyhy96 <hy352144278@gmail.com>
Date: Mon, 12 Apr 2021 16:13:40 +0800
Subject: [PATCH] fix: add sentAt when put item into pendingQueue

Signed-off-by: jonyhy96 <hy352144278@gmail.com>
---
 pulsar/producer_partition.go | 1 +
 1 file changed, 1 insertion(+)

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],