commit fbfdc195d40e43f54aa7809cd2a8bbaa314b4a5b
author Gwen Shapira <cshapi@gmail.com> Wed Jul 08 09:57:16 2015 -0700
committer Jun Rao <junrao@gmail.com> Wed Sep 02 16:49:56 2015 -0700
tree 91f74eb1cd8153f62b24ffe8676a7a168f60fe61
parent 30f1a44e657adf3fffea6832acacafe925c2c72d

KAFKA-2308: make MemoryRecords idempotent; reviewed by Guozhang Wang

clients/src/main/java/org/apache/kafka/common/record/MemoryRecords.java

diff --git a/clients/src/main/java/org/apache/kafka/common/record/MemoryRecords.java b/clients/src/main/java/org/apache/kafka/common/record/MemoryRecords.java
index 040e5b9..1d9f894 100644
--- a/clients/src/main/java/org/apache/kafka/common/record/MemoryRecords.java
+++ b/clients/src/main/java/org/apache/kafka/common/record/MemoryRecords.java
@@ -116,9 +116,11 @@
      * Close this batch for no more appends
      */
     public void close() {
-        compressor.close();
-        writable = false;
-        buffer = compressor.buffer();
+        if (writable) {
+            compressor.close();
+            writable = false;
+            buffer = compressor.buffer();
+        }
     }
 
     /** Write the records in this set to the given channel */