commit 31a1592f743d0efb5d393374d01e3eda9145cfff
author P. Taylor Goetz <ptgoetz@gmail.com> Fri Jun 13 15:12:24 2014 -0400
committer P. Taylor Goetz <ptgoetz@gmail.com> Fri Jun 13 15:12:24 2014 -0400
tree 164519f7ba3f81f2ad38232c1de27500bd432507
parent 87a16c1a885c6381a3bc1d532e5105660196a2cb
parent 57851bb6be4caec950541bcb1f01529224e52af4

Merge branch 'STORM-352'

external/storm-kafka/src/jvm/storm/kafka/PartitionManager.java

diff --git a/external/storm-kafka/src/jvm/storm/kafka/PartitionManager.java b/external/storm-kafka/src/jvm/storm/kafka/PartitionManager.java
index d868e50..2c32a2c 100644
--- a/external/storm-kafka/src/jvm/storm/kafka/PartitionManager.java
+++ b/external/storm-kafka/src/jvm/storm/kafka/PartitionManager.java
@@ -214,7 +214,7 @@
 
     public void commit() {
         long lastCompletedOffset = lastCompletedOffset();
-        if (lastCompletedOffset != lastCompletedOffset) {
+        if (_committedTo != lastCompletedOffset) {
             LOG.debug("Writing last completed offset (" + lastCompletedOffset + ") to ZK for " + _partition + " for topology: " + _topologyInstanceId);
             Map<Object, Object> data = (Map<Object, Object>) ImmutableMap.builder()
                     .put("topology", ImmutableMap.of("id", _topologyInstanceId,