Skip to content

Commit 67c9a5f

Browse files
authored
Removed old comment on cluster creation referring to KRaft migration (#11987)
Signed-off-by: Paolo Patierno <ppatierno@live.com>
1 parent c339562 commit 67c9a5f

1 file changed

Lines changed: 0 additions & 3 deletions

File tree

cluster-operator/src/main/java/io/strimzi/operator/cluster/operator/assembly/KafkaClusterCreator.java

Lines changed: 0 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -324,9 +324,6 @@ public static KafkaCluster createKafkaCluster(
324324
KafkaVersion.Lookup versions,
325325
SharedEnvironmentProvider sharedEnvironmentProvider
326326
) {
327-
// We prepare the KafkaPool models and create the KafkaCluster model
328-
// KRaft to be considered not only when fully enabled (KRAFT = 4) but also when a migration is about to start (PRE_MIGRATION = 1)
329-
// NOTE: this is important to drive the right validation happening in node pools (i.e. roles on node pools, storage, number of controllers, ...)
330327
List<KafkaPool> pools = NodePoolUtils.createKafkaPools(reconciliation, kafkaCr, nodePoolCrs, oldStorage, versionChange, sharedEnvironmentProvider);
331328
String clusterId = NodePoolUtils.getOrGenerateKRaftClusterId(kafkaCr, nodePoolCrs);
332329
return KafkaCluster.fromCrd(reconciliation, kafkaCr, pools, versions, versionChange, clusterId, sharedEnvironmentProvider);

0 commit comments

Comments
 (0)