fix bad logging message

Sunbird-Obsrv · Jul 15, 2015 · 5c31a46 · 5c31a46
1 parent 8d97a99
commit 5c31a46
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/src/main/java/com/pinterest/secor/common/OffsetTracker.java b/src/main/java/com/pinterest/secor/common/OffsetTracker.java
@@ -52,10 +52,10 @@ public long setLastSeenOffset(TopicPartition topicPartition, long offset) {
         mLastSeenOffset.put(topicPartition, offset);
         if (lastSeenOffset + 1 != offset) {
             if (lastSeenOffset >= 0) {
-                LOG.warn("offset for topic {} partition {}  changed from {} to {}",
+                LOG.warn("offset for topic {} partition {} changed from {} to {}",
                         topicPartition.getTopic(),topicPartition.getPartition(),lastSeenOffset, offset);
             } else {
-                LOG.info("starting to consume topic {} partition  from offset {}",
+                LOG.info("starting to consume topic {} partition {} from offset {}",
                         topicPartition.getTopic(),topicPartition.getPartition(),offset);
             }
         }