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); } }