diff --git a/core/src/main/java/kafka/log/remote/RemoteLogManager.java b/core/src/main/java/kafka/log/remote/RemoteLogManager.java index a2b7cd0b88d51..1048cd5020fc9 100644 --- a/core/src/main/java/kafka/log/remote/RemoteLogManager.java +++ b/core/src/main/java/kafka/log/remote/RemoteLogManager.java @@ -454,7 +454,7 @@ private void maybeUpdateReadOffset() throws RemoteStorageException { // This is found by traversing from the latest leader epoch from leader epoch history and find the highest offset // of a segment with that epoch copied into remote storage. If it can not find an entry then it checks for the // previous leader epoch till it finds an entry, If there are no entries till the earliest leader epoch in leader - // epoch cache then it starts copying the segments from the earliest epoch entry’s offset. + // epoch cache then it starts copying the segments from the earliest epoch entry's offset. copiedOffsetOption = OptionalLong.of(findHighestRemoteOffset(topicIdPartition)); } } diff --git a/core/src/test/java/kafka/log/remote/RemoteLogManagerTest.java b/core/src/test/java/kafka/log/remote/RemoteLogManagerTest.java index e56fbd45a08f2..c4cfc00b57b9c 100644 --- a/core/src/test/java/kafka/log/remote/RemoteLogManagerTest.java +++ b/core/src/test/java/kafka/log/remote/RemoteLogManagerTest.java @@ -202,7 +202,7 @@ void testStartup() { } // This test creates 2 log segments, 1st one has start offset of 0, 2nd one (and active one) has start offset of 150. - // The leader epochs are [0->0, 1->100, 2->200]. We are verifying: + // The leader epochs are [0->0, 1->100, 2->200]. We are verifying: // 1. There's only 1 segment copied to remote storage // 2. The segment got copied to remote storage is the old segment, not the active one // 3. The log segment metadata stored into remoteLogMetadataManager is what we expected, both before and after copying the log segments