rebase to master

gunli · gunli · commit e06eec761ce8 · 2025-03-10T15:11:59.000+08:00
diff --git a/pulsar/producer_partition.go b/pulsar/producer_partition.go
@@ -1743,14 +1743,14 @@ func (i *pendingItem) done(err error) {
 		return
 	}
 	i.isDone = true
-	buffersPool.Put(i.buffer)
 	if i.flushCallback != nil {
 		i.flushCallback(err)
 	}
 
 	if i.cancel != nil {
 		i.cancel()
 	}
+	buffersPool.Put(i.buffer)
 }
 
 // _setConn sets the internal connection field of this partition producer atomically.

Original file line number	Diff line number	Diff line change
`@@ -1743,14 +1743,14 @@ func (i *pendingItem) done(err error) {`
`1743`	`1743`	`return`
`1744`	`1744`	`}`
`1745`	`1745`	`i.isDone = true`
`1746`		`- buffersPool.Put(i.buffer)`
`1747`	`1746`	`if i.flushCallback != nil {`
`1748`	`1747`	`i.flushCallback(err)`
`1749`	`1748`	`}`
`1750`	`1749`
`1751`	`1750`	`if i.cancel != nil {`
`1752`	`1751`	`i.cancel()`
`1753`	`1752`	`}`
	`1753`	`+ buffersPool.Put(i.buffer)`
`1754`	`1754`	`}`
`1755`	`1755`
`1756`	`1756`	`// _setConn sets the internal connection field of this partition producer atomically.`