splett2 commented on code in PR #14053:
URL: https://github.com/apache/kafka/pull/14053#discussion_r1324902142
##
core/src/main/scala/kafka/cluster/Partition.scala:
##
@@ -864,13 +866,19 @@ class Partition(val topicPartition: TopicPartition,
// No need to calculate low wate
splett2 commented on code in PR #14053:
URL: https://github.com/apache/kafka/pull/14053#discussion_r1324845475
##
core/src/main/scala/kafka/cluster/Partition.scala:
##
@@ -137,7 +137,8 @@ object Partition {
delayedOperations = delayedOperations,
metadataCache = rep
splett2 commented on code in PR #14053:
URL: https://github.com/apache/kafka/pull/14053#discussion_r1322060958
##
core/src/main/scala/kafka/cluster/Replica.scala:
##
@@ -98,14 +103,21 @@ class Replica(val brokerId: Int, val topicPartition:
TopicPartition) extends Log
* fetc
splett2 commented on code in PR #14053:
URL: https://github.com/apache/kafka/pull/14053#discussion_r1322065839
##
core/src/main/scala/kafka/cluster/Partition.scala:
##
@@ -858,7 +859,7 @@ class Partition(val topicPartition: TopicPartition,
// No need to calculate low waterm
splett2 commented on code in PR #14053:
URL: https://github.com/apache/kafka/pull/14053#discussion_r1322065839
##
core/src/main/scala/kafka/cluster/Partition.scala:
##
@@ -858,7 +859,7 @@ class Partition(val topicPartition: TopicPartition,
// No need to calculate low waterm
splett2 commented on code in PR #14053:
URL: https://github.com/apache/kafka/pull/14053#discussion_r1322060958
##
core/src/main/scala/kafka/cluster/Replica.scala:
##
@@ -98,14 +103,21 @@ class Replica(val brokerId: Int, val topicPartition:
TopicPartition) extends Log
* fetc
splett2 commented on code in PR #14053:
URL: https://github.com/apache/kafka/pull/14053#discussion_r1268889660
##
core/src/main/scala/kafka/cluster/Partition.scala:
##
@@ -858,13 +858,28 @@ class Partition(val topicPartition: TopicPartition,
// No need to calculate low wate
splett2 commented on code in PR #14053:
URL: https://github.com/apache/kafka/pull/14053#discussion_r1268889660
##
core/src/main/scala/kafka/cluster/Partition.scala:
##
@@ -858,13 +858,28 @@ class Partition(val topicPartition: TopicPartition,
// No need to calculate low wate