OmniaGM commented on code in PR #15335:
URL: https://github.com/apache/kafka/pull/15335#discussion_r1553431953
##########
core/src/main/scala/kafka/cluster/Partition.scala:
##########
@@ -289,10 +300,11 @@ class Partition(val topicPartition: TopicPartition,
delayedOperations: DelayedOperations,
metadataCache: MetadataCache,
logManager: LogManager,
- alterIsrManager: AlterPartitionManager) extends Logging {
+ alterIsrManager: AlterPartitionManager,
+ @volatile private var _topicId: Option[Uuid] = None // TODO:
merge topicPartition and _topicId into TopicIdPartition once TopicId persist in
most of the code
Review Comment:
there is a jira that will be address this already which is
[KAFKA-16212](https://issues.apache.org/jira/browse/KAFKA-16212) I'll update
the comment
--
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: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
