diff --git a/internal/util/rocksmq/server/rocksmq/rocksmq_impl.go b/internal/util/rocksmq/server/rocksmq/rocksmq_impl.go
index 00421f31ee..323f083141 100644
--- a/internal/util/rocksmq/server/rocksmq/rocksmq_impl.go
+++ b/internal/util/rocksmq/server/rocksmq/rocksmq_impl.go
@@ -203,6 +203,7 @@ func (rmq *rocksmq) Produce(topicName string, messages []ProducerMessage) error
 	}
 
 	err = rmq.store.Write(gorocksdb.NewDefaultWriteOptions(), batch)
+	batch.Destroy()
 	if err != nil {
 		log.Debug("RocksMQ: write batch failed")
 		return err