satishd commented on a change in pull request #11390:
URL: https://github.com/apache/kafka/pull/11390#discussion_r767426396
##########
File path: core/src/main/scala/kafka/log/UnifiedLog.scala
##########
@@ -288,13 +292,21 @@ class UnifiedLog(@volatile var logStartOffset: Long,
@volatile var partitionMetadataFile : PartitionMetadataFile = null
+ //todo-tier it needs to be updated.
+ private val localLogStartOffset: Long = logStartOffset
Review comment:
It is a `val` for now and it is not needed to be declared as volatile
and the compiler does not allow too. This will be updated in the upcoming
changes to `var` and then it can be declared as volatile.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: jira-unsubscr...@kafka.apache.org
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
