jolshan commented on code in PR #13196:
URL: https://github.com/apache/kafka/pull/13196#discussion_r1107850529
##########
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?
--
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
