showuon commented on code in PR #13850:
URL: https://github.com/apache/kafka/pull/13850#discussion_r1236592041
##
core/src/main/scala/kafka/log/remote/RemoteIndexCache.scala:
##
@@ -167,64 +235,76 @@ class RemoteIndexCache(maxSize: Int = 1024,
remoteStorageManager: RemoteStorag
showuon commented on code in PR #13850:
URL: https://github.com/apache/kafka/pull/13850#discussion_r1236592041
##
core/src/main/scala/kafka/log/remote/RemoteIndexCache.scala:
##
@@ -167,64 +235,76 @@ class RemoteIndexCache(maxSize: Int = 1024,
remoteStorageManager: RemoteStorag
showuon commented on code in PR #13850:
URL: https://github.com/apache/kafka/pull/13850#discussion_r1233980545
##
core/src/test/scala/unit/kafka/log/remote/RemoteIndexCacheTest.scala:
##
@@ -117,51 +128,60 @@ class RemoteIndexCacheTest {
@Test
def testCacheEntryExpiry():
showuon commented on code in PR #13850:
URL: https://github.com/apache/kafka/pull/13850#discussion_r1233805956
##
core/src/test/scala/unit/kafka/log/remote/RemoteIndexCacheTest.scala:
##
@@ -170,44 +190,173 @@ class RemoteIndexCacheTest {
assertThrows(classOf[IllegalStateEx