dajac commented on code in PR #12187:
URL: https://github.com/apache/kafka/pull/12187#discussion_r880194784


##########
core/src/main/scala/kafka/server/ReplicaManager.scala:
##########
@@ -2141,23 +2141,22 @@ class ReplicaManager(val config: KafkaConfig,
             stateChangeLogger.trace(s"Unable to start fetching $tp with topic 
" +
               s"ID ${info.topicId} because the replica manager is shutting 
down.")
           } else {
-            if (isInControlledShutdown && 
!info.partition.isr.contains(config.brokerId)) {
-              // If we are in controlled shutdown and the replica is not in 
the ISR,
-              // we stop the replica.
+            // We always update the follower state.

Review Comment:
   Yeah. That seems to be the right thing to do. I have looked at the 
dependencies on that state and I haven't identified any issues so far.



-- 
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

Reply via email to