[GitHub] [kafka] splett2 commented on a diff in pull request #14053: KAFKA-15221; Fix the race between fetch requests from a rebooted follower.

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

[GitHub] [kafka] splett2 commented on a diff in pull request #14053: KAFKA-15221; Fix the race between fetch requests from a rebooted follower.

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 =

[GitHub] [kafka] splett2 commented on a diff in pull request #14053: KAFKA-15221; Fix the race between fetch requests from a rebooted follower.

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 *

[GitHub] [kafka] splett2 commented on a diff in pull request #14053: KAFKA-15221; Fix the race between fetch requests from a rebooted follower.

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

[GitHub] [kafka] splett2 commented on a diff in pull request #14053: KAFKA-15221; Fix the race between fetch requests from a rebooted follower.

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

[GitHub] [kafka] splett2 commented on a diff in pull request #14053: KAFKA-15221; Fix the race between fetch requests from a rebooted follower.

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 *

[GitHub] [kafka] splett2 commented on a diff in pull request #14053: [KAFKA-15221] Fix the race between fetch requests from a rebooted follower.

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

[GitHub] [kafka] splett2 commented on a diff in pull request #14053: [KAFKA-15221] Fix the race between fetch requests from a rebooted follower.

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