fix(kafka-mgmt/v1): update kafka-mgmt/v1 SDK (#378)

Co-authored-by: app-services-ci <app-services-ci@users.noreply.github.com>

Author: app-services-ci

.openapi/kas-fleet-manager.yaml

@@ -1625,6 +1625,7 @@ components:
         - cluster_id
         - cluster_external_id
         - cluster_ingress_dns_name
+        - kafka_machine_pool_node_count
       type: object
       properties:
         cluster_id:
@@ -1636,6 +1637,15 @@ components:
         cluster_ingress_dns_name:
           description: dns name of the cluster. Can be obtained from the response JSON of the /api/clusters_mgmt/v1/clusters/<cluster_id>/ingresses (dns_name)
           type: string
+        kafka_machine_pool_node_count:
+          description: |-
+            The node count given to the created kafka machine pool. 
+            The machine pool must be created via /api/clusters_mgmt/v1/clusters/<cluster_id>/machine_pools prior to passing this value.
+            The created machine pool must have a `bf2.org/kafkaInstanceProfileType=standard` label and a `bf2.org/kafkaInstanceProfileType=standard:NoExecute` taint.
+            The name of the machine pool must be `kafka-standard` 
+            The node count value has to be a multiple of 3 with a minimum of 3 nodes.
+          type: integer
+          format: int32  
     EnterpriseCluster:
       description: Enterprise cluster registration endpoint response
       allOf:

packages/kafka-management-sdk/api/openapi.yaml

@@ -2199,6 +2199,7 @@ components:
     EnterpriseOsdClusterPayload:
       description: Schema for the request body sent to /clusters POST
       example:
+        kafka_machine_pool_node_count: 0
         cluster_id: cluster_id
         cluster_external_id: cluster_external_id
         cluster_ingress_dns_name: cluster_ingress_dns_name
@@ -2214,10 +2215,20 @@ components:
           description: dns name of the cluster. Can be obtained from the response
             JSON of the /api/clusters_mgmt/v1/clusters/<cluster_id>/ingresses (dns_name)
           type: string
+        kafka_machine_pool_node_count:
+          description: "The node count given to the created kafka machine pool. \n\
+            The machine pool must be created via /api/clusters_mgmt/v1/clusters/<cluster_id>/machine_pools\
+            \ prior to passing this value.\nThe created machine pool must have a `bf2.org/kafkaInstanceProfileType=standard`\
+            \ label and a `bf2.org/kafkaInstanceProfileType=standard:NoExecute` taint.\n\
+            The name of the machine pool must be `kafka-standard` \nThe node count\
+            \ value has to be a multiple of 3 with a minimum of 3 nodes."
+          format: int32
+          type: integer
       required:
       - cluster_external_id
       - cluster_id
       - cluster_ingress_dns_name
+      - kafka_machine_pool_node_count
       type: object
     EnterpriseCluster:
       allOf:

packages/kafka-management-sdk/docs/EnterpriseOsdClusterPayload.md

@@ -11,6 +11,7 @@ Name | Type | Description | Notes
 **clusterId** | **String** | OSD cluster ID | 
 **clusterExternalId** | **String** | external cluster ID. Can be obtained from the response JSON of ocm get /api/clusters_mgmt/v1/clusters/<cluster_id> | 
 **clusterIngressDnsName** | **String** | dns name of the cluster. Can be obtained from the response JSON of the /api/clusters_mgmt/v1/clusters/<cluster_id>/ingresses (dns_name) | 
+**kafkaMachinePoolNodeCount** | **Integer** | The node count given to the created kafka machine pool.  The machine pool must be created via /api/clusters_mgmt/v1/clusters/<cluster_id>/machine_pools prior to passing this value. The created machine pool must have a `bf2.org/kafkaInstanceProfileType=standard` label and a `bf2.org/kafkaInstanceProfileType=standard:NoExecute` taint. The name of the machine pool must be `kafka-standard`  The node count value has to be a multiple of 3 with a minimum of 3 nodes. | 
 
 
 

packages/kafka-management-sdk/src/main/java/com/openshift/cloud/api/kas/models/EnterpriseOsdClusterPayload.java

@@ -32,7 +32,8 @@
 @JsonPropertyOrder({
   EnterpriseOsdClusterPayload.JSON_PROPERTY_CLUSTER_ID,
   EnterpriseOsdClusterPayload.JSON_PROPERTY_CLUSTER_EXTERNAL_ID,
-  EnterpriseOsdClusterPayload.JSON_PROPERTY_CLUSTER_INGRESS_DNS_NAME
+  EnterpriseOsdClusterPayload.JSON_PROPERTY_CLUSTER_INGRESS_DNS_NAME,
+  EnterpriseOsdClusterPayload.JSON_PROPERTY_KAFKA_MACHINE_POOL_NODE_COUNT
 })
 @JsonTypeName("EnterpriseOsdClusterPayload")
 @javax.annotation.Generated(value = "org.openapitools.codegen.languages.JavaClientCodegen")
@@ -46,6 +47,9 @@ public class EnterpriseOsdClusterPayload {
   public static final String JSON_PROPERTY_CLUSTER_INGRESS_DNS_NAME = "cluster_ingress_dns_name";
   private String clusterIngressDnsName;
 
+  public static final String JSON_PROPERTY_KAFKA_MACHINE_POOL_NODE_COUNT = "kafka_machine_pool_node_count";
+  private Integer kafkaMachinePoolNodeCount;
+
   public EnterpriseOsdClusterPayload() { 
   }
 
@@ -130,6 +134,33 @@ public void setClusterIngressDnsName(String clusterIngressDnsName) {
   }
 
 
+  public EnterpriseOsdClusterPayload kafkaMachinePoolNodeCount(Integer kafkaMachinePoolNodeCount) {
+    
+    this.kafkaMachinePoolNodeCount = kafkaMachinePoolNodeCount;
+    return this;
+  }
+
+   /**
+   * The node count given to the created kafka machine pool.  The machine pool must be created via /api/clusters_mgmt/v1/clusters/<cluster_id>/machine_pools prior to passing this value. The created machine pool must have a `bf2.org/kafkaInstanceProfileType=standard` label and a `bf2.org/kafkaInstanceProfileType=standard:NoExecute` taint. The name of the machine pool must be `kafka-standard`  The node count value has to be a multiple of 3 with a minimum of 3 nodes.
+   * @return kafkaMachinePoolNodeCount
+  **/
+  @javax.annotation.Nonnull
+  @ApiModelProperty(required = true, value = "The node count given to the created kafka machine pool.  The machine pool must be created via /api/clusters_mgmt/v1/clusters/<cluster_id>/machine_pools prior to passing this value. The created machine pool must have a `bf2.org/kafkaInstanceProfileType=standard` label and a `bf2.org/kafkaInstanceProfileType=standard:NoExecute` taint. The name of the machine pool must be `kafka-standard`  The node count value has to be a multiple of 3 with a minimum of 3 nodes.")
+  @JsonProperty(JSON_PROPERTY_KAFKA_MACHINE_POOL_NODE_COUNT)
+  @JsonInclude(value = JsonInclude.Include.ALWAYS)
+
+  public Integer getKafkaMachinePoolNodeCount() {
+    return kafkaMachinePoolNodeCount;
+  }
+
+
+  @JsonProperty(JSON_PROPERTY_KAFKA_MACHINE_POOL_NODE_COUNT)
+  @JsonInclude(value = JsonInclude.Include.ALWAYS)
+  public void setKafkaMachinePoolNodeCount(Integer kafkaMachinePoolNodeCount) {
+    this.kafkaMachinePoolNodeCount = kafkaMachinePoolNodeCount;
+  }
+
+
   @Override
   public boolean equals(Object o) {
     if (this == o) {
@@ -141,12 +172,13 @@ public boolean equals(Object o) {
     EnterpriseOsdClusterPayload enterpriseOsdClusterPayload = (EnterpriseOsdClusterPayload) o;
     return Objects.equals(this.clusterId, enterpriseOsdClusterPayload.clusterId) &&
         Objects.equals(this.clusterExternalId, enterpriseOsdClusterPayload.clusterExternalId) &&
-        Objects.equals(this.clusterIngressDnsName, enterpriseOsdClusterPayload.clusterIngressDnsName);
+        Objects.equals(this.clusterIngressDnsName, enterpriseOsdClusterPayload.clusterIngressDnsName) &&
+        Objects.equals(this.kafkaMachinePoolNodeCount, enterpriseOsdClusterPayload.kafkaMachinePoolNodeCount);
   }
 
   @Override
   public int hashCode() {
-    return Objects.hash(clusterId, clusterExternalId, clusterIngressDnsName);
+    return Objects.hash(clusterId, clusterExternalId, clusterIngressDnsName, kafkaMachinePoolNodeCount);
   }
 
   @Override
@@ -156,6 +188,7 @@ public String toString() {
     sb.append("    clusterId: ").append(toIndentedString(clusterId)).append("\n");
     sb.append("    clusterExternalId: ").append(toIndentedString(clusterExternalId)).append("\n");
     sb.append("    clusterIngressDnsName: ").append(toIndentedString(clusterIngressDnsName)).append("\n");
+    sb.append("    kafkaMachinePoolNodeCount: ").append(toIndentedString(kafkaMachinePoolNodeCount)).append("\n");
     sb.append("}");
     return sb.toString();
   }