dajac commented on code in PR #13196: URL: https://github.com/apache/kafka/pull/13196#discussion_r1108755781
########## core/src/main/scala/kafka/cluster/Partition.scala: ########## @@ -285,6 +314,17 @@ class Partition(val topicPartition: TopicPartition, // If ReplicaAlterLogDir command is in progress, this is future location of the log @volatile var futureLog: Option[UnifiedLog] = None + // Partition listeners + private val listeners = new CopyOnWriteArrayList[PartitionListener]() + + private val logOffsetsListener = new LogOffsetsListener { + override def onHighWatermarkUpdated(offset: Long): Unit = { Review Comment: > For my understanding, they way we update the Partition Listeners is that we have our own Log layer listener we rely on for this purpose? That's correct. > Will we use the logOffsetsListener for any other purposes? Not at the moment. -- 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