| commit | b4ec53c8bc0b229cc3bf8197c27f4d0ee2378913 | [log] [tgz] |
|---|---|---|
| author | jony montana <hy352144278@gmail.com> | Thu Apr 15 11:59:58 2021 +0800 |
| committer | GitHub <noreply@github.com> | Thu Apr 15 11:59:58 2021 +0800 |
| tree | 359f3f4a8d4181877dbce27f2510740817eee7df | |
| parent | f17deac7ac47919aa9e46d11d33638672a24d126 [diff] |
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
diff --git a/pulsar/producer_partition.go b/pulsar/producer_partition.go index 87c97ed..b365f83 100644 --- a/pulsar/producer_partition.go +++ b/pulsar/producer_partition.go
@@ -547,6 +547,7 @@ continue } p.pendingQueue.Put(&pendingItem{ + sentAt: time.Now(), batchData: batchesData[i], sequenceID: sequenceIDs[i], sendRequests: callbacks[i],