dajac commented on a change in pull request #11225:
URL: https://github.com/apache/kafka/pull/11225#discussion_r694960197
##
File path: core/src/main/scala/kafka/server/ReplicaManager.scala
##
@@ -2207,15 +2198,28 @@ class ReplicaManager(val config: KafkaConfig,
dajac commented on a change in pull request #11225:
URL: https://github.com/apache/kafka/pull/11225#discussion_r694960458
##
File path: core/src/main/scala/kafka/server/ReplicaManager.scala
##
@@ -2207,15 +2198,28 @@ class ReplicaManager(val config: KafkaConfig,
dajac commented on a change in pull request #11225:
URL: https://github.com/apache/kafka/pull/11225#discussion_r693979039
##
File path: core/src/main/scala/kafka/server/ReplicaManager.scala
##
@@ -1436,17 +1438,15 @@ class ReplicaManager(val config: KafkaConfig,
le
dajac commented on a change in pull request #11225:
URL: https://github.com/apache/kafka/pull/11225#discussion_r693973004
##
File path: core/src/main/scala/kafka/server/ReplicaManager.scala
##
@@ -1436,17 +1438,15 @@ class ReplicaManager(val config: KafkaConfig,
le
dajac commented on a change in pull request #11225:
URL: https://github.com/apache/kafka/pull/11225#discussion_r691041467
##
File path: core/src/main/scala/kafka/server/ReplicaManager.scala
##
@@ -1436,17 +1438,15 @@ class ReplicaManager(val config: KafkaConfig,
le
dajac commented on a change in pull request #11225:
URL: https://github.com/apache/kafka/pull/11225#discussion_r691041467
##
File path: core/src/main/scala/kafka/server/ReplicaManager.scala
##
@@ -1436,17 +1438,15 @@ class ReplicaManager(val config: KafkaConfig,
le