diff --git a/storage/src/main/java/org/apache/kafka/storage/internals/log/TimeIndex.java b/storage/src/main/java/org/apache/kafka/storage/internals/log/TimeIndex.java index f221cf4b0e0a..e1ade8c53143 100644 --- a/storage/src/main/java/org/apache/kafka/storage/internals/log/TimeIndex.java +++ b/storage/src/main/java/org/apache/kafka/storage/internals/log/TimeIndex.java @@ -66,7 +66,7 @@ public TimeIndex(File file, long baseOffset, int maxIndexSize, boolean writable) this.lastEntry = lastEntryFromIndexFile(); log.debug("Loaded index file {} with maxEntries = {}, maxIndexSize = {}, entries = {}, lastOffset = {}, file position = {}", - file.getAbsolutePath(), maxEntries(), maxIndexSize, entries(), lastEntry, mmap().position()); + file.getAbsolutePath(), maxEntries(), maxIndexSize, entries(), lastEntry.offset, mmap().position()); } @Override @@ -278,7 +278,7 @@ private void truncateToEntries(int entries) { super.truncateToEntries0(entries); this.lastEntry = lastEntryFromIndexFile(); log.debug("Truncated index {} to {} entries; position is now {} and last entry is now {}", - file().getAbsolutePath(), entries, mmap().position(), lastEntry); + file().getAbsolutePath(), entries, mmap().position(), lastEntry.offset); } finally { lock.unlock(); } diff --git a/storage/src/main/java/org/apache/kafka/storage/internals/log/TimestampOffset.java b/storage/src/main/java/org/apache/kafka/storage/internals/log/TimestampOffset.java index 9b48352c2137..9dc35ae32d4b 100644 --- a/storage/src/main/java/org/apache/kafka/storage/internals/log/TimestampOffset.java +++ b/storage/src/main/java/org/apache/kafka/storage/internals/log/TimestampOffset.java @@ -67,4 +67,11 @@ public int hashCode() { result = 31 * result + Long.hashCode(offset); return result; } + + @Override + public String toString() { + return String.format("TimestampOffset(offset = %d, timestamp = %d)", + offset, + timestamp); + } }