kowshik commented on a change in pull request #11154:
URL: https://github.com/apache/kafka/pull/11154#discussion_r684599225
##
File path: core/src/main/scala/kafka/log/UnifiedLog.scala
##
@@ -1738,12 +1747,12 @@ object Log extends Logging {
logDirFailureChannel: Lo
kowshik commented on a change in pull request #11154:
URL: https://github.com/apache/kafka/pull/11154#discussion_r683616272
##
File path: core/src/main/scala/kafka/log/UnifiedLog.scala
##
@@ -248,16 +250,16 @@ case object SnapshotGenerated extends
LogStartOffsetIncrementReason
kowshik commented on a change in pull request #11154:
URL: https://github.com/apache/kafka/pull/11154#discussion_r680529799
##
File path: core/src/main/scala/kafka/log/UnifiedLog.scala
##
@@ -540,6 +542,13 @@ class Log(@volatile var logStartOffset: Long,
}
}, period = p