You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by gu...@apache.org on 2015/07/08 18:57:37 UTC
kafka git commit: KAFKA-2308: make MemoryRecords idempotent;
reviewed by Guozhang Wang
Repository: kafka
Updated Branches:
refs/heads/trunk 4204f4a06 -> 67b6b9a45
KAFKA-2308: make MemoryRecords idempotent; reviewed by Guozhang Wang
Project: http://git-wip-us.apache.org/repos/asf/kafka/repo
Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/67b6b9a4
Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/67b6b9a4
Diff: http://git-wip-us.apache.org/repos/asf/kafka/diff/67b6b9a4
Branch: refs/heads/trunk
Commit: 67b6b9a45ba6f096645f4f344dfdcf1df1e50dd6
Parents: 4204f4a
Author: Gwen Shapira <cs...@gmail.com>
Authored: Wed Jul 8 09:57:16 2015 -0700
Committer: Guozhang Wang <wa...@gmail.com>
Committed: Wed Jul 8 09:57:16 2015 -0700
----------------------------------------------------------------------
.../java/org/apache/kafka/common/record/MemoryRecords.java | 8 +++++---
1 file changed, 5 insertions(+), 3 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/kafka/blob/67b6b9a4/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 b2db240..5f1b45c 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
@@ -115,9 +115,11 @@ public class MemoryRecords implements Records {
* 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 */