From 5c31a4662521d17f1959a9878a99c014b32f9683 Mon Sep 17 00:00:00 2001 From: Christian Nguyen Van Than Date: Wed, 15 Jul 2015 15:35:30 +0200 Subject: [PATCH] fix bad logging message --- src/main/java/com/pinterest/secor/common/OffsetTracker.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/src/main/java/com/pinterest/secor/common/OffsetTracker.java b/src/main/java/com/pinterest/secor/common/OffsetTracker.java index 8fff6eb70..4a390ca84 100644 --- 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); } }