Support Kafka Shrink operation. (#92)

confluentinc · Oct 28, 2021 · 55026c4 · 55026c4
1 parent 483d57c
commit 55026c4
Showing 1 changed file with 4 additions and 1 deletion.
diff --git a/internal/provider/resource_kafka_cluster.go b/internal/provider/resource_kafka_cluster.go
@@ -184,7 +184,10 @@ func kafkaUpdate(ctx context.Context, d *schema.ResourceData, meta interface{})
 	if isCkuUpdate {
 		oldCku, newCku := d.GetChange(paramDedicatedCku)
 		if newCku.(int) < oldCku.(int) {
-			return diag.FromErr(fmt.Errorf("decreasing the number of CKUs is currently not supported"))
+			// decreasing the number of CKUs aka Kafka Shrink operation
+			if newCku.(int)+1 != oldCku.(int) {
+				return diag.FromErr(fmt.Errorf("decreasing the number of CKUs by more than 1 is currently not supported"))
+			}
 		}
 		availability := extractAvailability(d)
 		err = ckuCheck(cku, availability)