Skip to content

Commit d0d8eeb

Browse files
authored
Fixed minor typo and indentation (strimzi#10152)
Signed-off-by: Paolo Patierno <[email protected]>
1 parent 7ce156a commit d0d8eeb

File tree

3 files changed

+8
-6
lines changed

3 files changed

+8
-6
lines changed

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

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -694,7 +694,7 @@ Future<KafkaReconciler> kafkaReconciler() {
694694
.prepareKafkaCluster(kafkaAssembly, nodePools, oldStorage, currentPods, versionChange, kafkaStatus, true)
695695
.compose(kafkaCluster -> {
696696
// We store this for use with Cruise Control later. As these configurations might
697-
// not be exactly hte same as in the original custom resource (for example because
697+
// not be exactly the same as in the original custom resource (for example because
698698
// of un-allowed storage changes being reverted) they are passed this way from the
699699
// KafkaCluster object and not from the custom resource.
700700
kafkaBrokerNodes = kafkaCluster.brokerNodes();

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

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -227,9 +227,9 @@ private Future<KafkaAndNodePools> revertScaleDown(KafkaCluster kafka, Kafka kafk
227227

228228
Kafka newKafkaCr = new KafkaBuilder(kafkaCr)
229229
.editSpec()
230-
.editKafka()
231-
.withReplicas(newReplicasCount)
232-
.endKafka()
230+
.editKafka()
231+
.withReplicas(newReplicasCount)
232+
.endKafka()
233233
.endSpec()
234234
.build();
235235

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

Lines changed: 4 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -808,8 +808,10 @@ protected Future<Void> migrateFromStatefulSetToPodSet() {
808808
}
809809

810810
/**
811-
* Create or update the StrimziPodSet for the Kafka cluster. If set, it uses the old replica count since scaling-up
812-
* happens only later in a separate step.
811+
* Create or update the StrimziPodSet for the Kafka cluster.
812+
* If the StrimziPodSet is updated with additional pods (Kafka cluster scaled up), it's the StrimziPodSet controller
813+
* taking care of reconciling within this method and starting up the new nodes.
814+
* The opposite (Kafka cluster scaled down) is handled by a dedicated scaleDown() method instead.
813815
*
814816
* @return Future which completes when the PodSet is created, updated or deleted
815817
*/

0 commit comments

Comments
 (0)