From c677597a462b2247f97a0520bcb8499815e61cfe Mon Sep 17 00:00:00 2001
From: rfyiamcool <rfyiamcool@163.com>
Date: Thu, 19 Oct 2023 12:06:30 +0800
Subject: [PATCH] fix: flush block

Signed-off-by: rfyiamcool <rfyiamcool@163.com>
---
 pulsar/producer_partition.go | 5 +++++
 1 file changed, 5 insertions(+)

diff --git a/pulsar/producer_partition.go b/pulsar/producer_partition.go
index ebd292ec11..059d4bbb9d 100755
--- a/pulsar/producer_partition.go
+++ b/pulsar/producer_partition.go
@@ -1381,6 +1381,11 @@ func (p *partitionProducer) LastSequenceID() int64 {
 }
 
 func (p *partitionProducer) Flush() error {
+	if p.getProducerState() != producerReady {
+		// Producer is closing
+		return errProducerClosed
+	}
+
 	flushReq := &flushRequest{
 		doneCh: make(chan struct{}),
 		err:    nil,