kowshik commented on a change in pull request #9001:
URL: https://github.com/apache/kafka/pull/9001#discussion_r494519631
##########
File path: core/src/main/scala/kafka/controller/KafkaController.scala
##########
@@ -977,14 +1179,30 @@ class KafkaController(val config: KafkaConfig,
/**
* Send the leader information for selected partitions to selected brokers
so that they can correctly respond to
- * metadata requests
+ * metadata requests. Particularly, when feature versioning is enabled, we
filter out brokers with incompatible
+ * features from receiving the metadata requests. This is because we do not
want to activate incompatible brokers,
+ * as these may have harmful consequences to the cluster.
Review comment:
Done. I've changed the code such that we skip the broker registration if
it's detected as incompatible.
----------------------------------------------------------------
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.
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
