diff --git a/core/src/main/scala/kafka/server/KafkaApis.scala b/core/src/main/scala/kafka/server/KafkaApis.scala
index 3684817fda..3d914361c0 100644
--- a/core/src/main/scala/kafka/server/KafkaApis.scala
+++ b/core/src/main/scala/kafka/server/KafkaApis.scala
@@ -996,7 +996,7 @@ class KafkaApis(val requestChannel: RequestChannel,
 
       def release(): Unit = {
         partitions.values().forEach(data => {
-          if (data.records() != null) {
+          if (data.records() != null && data.records().isInstanceOf[PooledResource]) {
             data.records().asInstanceOf[PooledResource].release()
           }
         })