[EventHub] Add support for 2026-01-01 API version

sdk/eventhubs/azure-resourcemanager-eventhubs/CHANGELOG.md

@@ -4,6 +4,8 @@
 
 ### Features Added
 
+- Added support for the `2026-01-01` API version.
+- Added `ipAddressType` (IPv4 / DualStack) to the Event Hubs namespace.
 - Supported `disableLocalAuth()` and `enableLocalAuth()` in `EventHubNamespace`.
 
 ### Breaking Changes

sdk/eventhubs/azure-resourcemanager-eventhubs/src/main/java/com/azure/resourcemanager/eventhubs/fluent/NamespacesClient.java

@@ -218,58 +218,9 @@ EHNamespaceInner createOrUpdate(String resourceGroupName, String namespaceName,
      * {@link Mono}.
      */
     @ServiceMethod(returns = ReturnType.SINGLE)
-    Mono<Response<Flux<ByteBuffer>>> updateWithResponseAsync(String resourceGroupName, String namespaceName,
+    Mono<Response<EHNamespaceInner>> updateWithResponseAsync(String resourceGroupName, String namespaceName,
         EHNamespaceInner parameters);
 
-    /**
-     * Creates or updates a namespace. Once created, this namespace's resource manifest is immutable. This operation is
-     * idempotent.
-     * 
-     * @param resourceGroupName The name of the resource group. The name is case insensitive.
-     * @param namespaceName The Namespace name.
-     * @param parameters Parameters for updating a namespace resource.
-     * @throws IllegalArgumentException thrown if parameters fail the validation.
-     * @throws com.azure.core.management.exception.ManagementException thrown if the request is rejected by server.
-     * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
-     * @return the {@link PollerFlux} for polling of single Namespace item in List or Get Operation.
-     */
-    @ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION)
-    PollerFlux<PollResult<EHNamespaceInner>, EHNamespaceInner> beginUpdateAsync(String resourceGroupName,
-        String namespaceName, EHNamespaceInner parameters);
-
-    /**
-     * Creates or updates a namespace. Once created, this namespace's resource manifest is immutable. This operation is
-     * idempotent.
-     * 
-     * @param resourceGroupName The name of the resource group. The name is case insensitive.
-     * @param namespaceName The Namespace name.
-     * @param parameters Parameters for updating a namespace resource.
-     * @throws IllegalArgumentException thrown if parameters fail the validation.
-     * @throws com.azure.core.management.exception.ManagementException thrown if the request is rejected by server.
-     * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
-     * @return the {@link SyncPoller} for polling of single Namespace item in List or Get Operation.
-     */
-    @ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION)
-    SyncPoller<PollResult<EHNamespaceInner>, EHNamespaceInner> beginUpdate(String resourceGroupName,
-        String namespaceName, EHNamespaceInner parameters);
-
-    /**
-     * Creates or updates a namespace. Once created, this namespace's resource manifest is immutable. This operation is
-     * idempotent.
-     * 
-     * @param resourceGroupName The name of the resource group. The name is case insensitive.
-     * @param namespaceName The Namespace name.
-     * @param parameters Parameters for updating a namespace resource.
-     * @param context The context to associate with this operation.
-     * @throws IllegalArgumentException thrown if parameters fail the validation.
-     * @throws com.azure.core.management.exception.ManagementException thrown if the request is rejected by server.
-     * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
-     * @return the {@link SyncPoller} for polling of single Namespace item in List or Get Operation.
-     */
-    @ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION)
-    SyncPoller<PollResult<EHNamespaceInner>, EHNamespaceInner> beginUpdate(String resourceGroupName,
-        String namespaceName, EHNamespaceInner parameters, Context context);
-
     /**
      * Creates or updates a namespace. Once created, this namespace's resource manifest is immutable. This operation is
      * idempotent.
@@ -292,13 +243,15 @@ SyncPoller<PollResult<EHNamespaceInner>, EHNamespaceInner> beginUpdate(String re
      * @param resourceGroupName The name of the resource group. The name is case insensitive.
      * @param namespaceName The Namespace name.
      * @param parameters Parameters for updating a namespace resource.
+     * @param context The context to associate with this operation.
      * @throws IllegalArgumentException thrown if parameters fail the validation.
      * @throws com.azure.core.management.exception.ManagementException thrown if the request is rejected by server.
      * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
-     * @return single Namespace item in List or Get Operation.
+     * @return single Namespace item in List or Get Operation along with {@link Response}.
      */
     @ServiceMethod(returns = ReturnType.SINGLE)
-    EHNamespaceInner update(String resourceGroupName, String namespaceName, EHNamespaceInner parameters);
+    Response<EHNamespaceInner> updateWithResponse(String resourceGroupName, String namespaceName,
+        EHNamespaceInner parameters, Context context);
 
     /**
      * Creates or updates a namespace. Once created, this namespace's resource manifest is immutable. This operation is
@@ -307,15 +260,13 @@ SyncPoller<PollResult<EHNamespaceInner>, EHNamespaceInner> beginUpdate(String re
      * @param resourceGroupName The name of the resource group. The name is case insensitive.
      * @param namespaceName The Namespace name.
      * @param parameters Parameters for updating a namespace resource.
-     * @param context The context to associate with this operation.
      * @throws IllegalArgumentException thrown if parameters fail the validation.
      * @throws com.azure.core.management.exception.ManagementException thrown if the request is rejected by server.
      * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
      * @return single Namespace item in List or Get Operation.
      */
     @ServiceMethod(returns = ReturnType.SINGLE)
-    EHNamespaceInner update(String resourceGroupName, String namespaceName, EHNamespaceInner parameters,
-        Context context);
+    EHNamespaceInner update(String resourceGroupName, String namespaceName, EHNamespaceInner parameters);
 
     /**
      * Deletes an existing namespace. This operation also removes all associated resources under the namespace.

sdk/eventhubs/azure-resourcemanager-eventhubs/src/main/java/com/azure/resourcemanager/eventhubs/fluent/models/ClusterInner.java

@@ -27,19 +27,19 @@ public final class ClusterInner extends Resource {
     private ClusterProperties innerProperties;
 
     /*
-     * Resource tags.
+     * Properties of the cluster SKU.
      */
-    private Map<String, String> tags;
+    private ClusterSku sku;
 
     /*
-     * The geo-location where the resource lives
+     * Resource location.
      */
     private String location;
 
     /*
-     * Properties of the cluster SKU.
+     * Resource tags.
      */
-    private ClusterSku sku;
+    private Map<String, String> tags;
 
     /*
      * Azure Resource Manager metadata containing createdBy and modifiedBy information.
@@ -77,27 +77,27 @@ private ClusterProperties innerProperties() {
     }
 
     /**
-     * Get the tags property: Resource tags.
+     * Get the sku property: Properties of the cluster SKU.
      *
-     * @return the tags value.
+     * @return the sku value.
      */
-    public Map<String, String> tags() {
-        return this.tags;
+    public ClusterSku sku() {
+        return this.sku;
     }
 
     /**
-     * Set the tags property: Resource tags.
+     * Set the sku property: Properties of the cluster SKU.
      *
-     * @param tags the tags value to set.
+     * @param sku the sku value to set.
      * @return the ClusterInner object itself.
      */
-    public ClusterInner withTags(Map<String, String> tags) {
-        this.tags = tags;
+    public ClusterInner withSku(ClusterSku sku) {
+        this.sku = sku;
         return this;
     }
 
     /**
-     * Get the location property: The geo-location where the resource lives.
+     * Get the location property: Resource location.
      *
      * @return the location value.
      */
@@ -106,7 +106,7 @@ public String location() {
     }
 
     /**
-     * Set the location property: The geo-location where the resource lives.
+     * Set the location property: Resource location.
      *
      * @param location the location value to set.
      * @return the ClusterInner object itself.
@@ -117,22 +117,22 @@ public ClusterInner withLocation(String location) {
     }
 
     /**
-     * Get the sku property: Properties of the cluster SKU.
+     * Get the tags property: Resource tags.
      *
-     * @return the sku value.
+     * @return the tags value.
      */
-    public ClusterSku sku() {
-        return this.sku;
+    public Map<String, String> tags() {
+        return this.tags;
     }
 
     /**
-     * Set the sku property: Properties of the cluster SKU.
+     * Set the tags property: Resource tags.
      *
-     * @param sku the sku value to set.
+     * @param tags the tags value to set.
      * @return the ClusterInner object itself.
      */
-    public ClusterInner withSku(ClusterSku sku) {
-        this.sku = sku;
+    public ClusterInner withTags(Map<String, String> tags) {
+        this.tags = tags;
         return this;
     }
 
@@ -267,6 +267,29 @@ public ClusterInner withPlatformCapabilities(PlatformCapabilities platformCapabi
         return this;
     }
 
+    /**
+     * Get the zoneRedundant property: A value that indicates whether the cluster is zone redundant.
+     *
+     * @return the zoneRedundant value.
+     */
+    public Boolean zoneRedundant() {
+        return this.innerProperties() == null ? null : this.innerProperties().zoneRedundant();
+    }
+
+    /**
+     * Set the zoneRedundant property: A value that indicates whether the cluster is zone redundant.
+     *
+     * @param zoneRedundant the zoneRedundant value to set.
+     * @return the ClusterInner object itself.
+     */
+    public ClusterInner withZoneRedundant(Boolean zoneRedundant) {
+        if (this.innerProperties() == null) {
+            this.innerProperties = new ClusterProperties();
+        }
+        this.innerProperties().withZoneRedundant(zoneRedundant);
+        return this;
+    }
+
     /**
      * Validates the instance.
      *
@@ -288,9 +311,9 @@ public void validate() {
     public JsonWriter toJson(JsonWriter jsonWriter) throws IOException {
         jsonWriter.writeStartObject();
         jsonWriter.writeJsonField("properties", this.innerProperties);
-        jsonWriter.writeMapField("tags", this.tags, (writer, element) -> writer.writeString(element));
-        jsonWriter.writeStringField("location", this.location);
         jsonWriter.writeJsonField("sku", this.sku);
+        jsonWriter.writeStringField("location", this.location);
+        jsonWriter.writeMapField("tags", this.tags, (writer, element) -> writer.writeString(element));
         return jsonWriter.writeEndObject();
     }
 
@@ -317,13 +340,13 @@ public static ClusterInner fromJson(JsonReader jsonReader) throws IOException {
                     deserializedClusterInner.type = reader.getString();
                 } else if ("properties".equals(fieldName)) {
                     deserializedClusterInner.innerProperties = ClusterProperties.fromJson(reader);
+                } else if ("sku".equals(fieldName)) {
+                    deserializedClusterInner.sku = ClusterSku.fromJson(reader);
+                } else if ("location".equals(fieldName)) {
+                    deserializedClusterInner.location = reader.getString();
                 } else if ("tags".equals(fieldName)) {
                     Map<String, String> tags = reader.readMap(reader1 -> reader1.getString());
                     deserializedClusterInner.tags = tags;
-                } else if ("location".equals(fieldName)) {
-                    deserializedClusterInner.location = reader.getString();
-                } else if ("sku".equals(fieldName)) {
-                    deserializedClusterInner.sku = ClusterSku.fromJson(reader);
                 } else if ("systemData".equals(fieldName)) {
                     deserializedClusterInner.systemData = SystemData.fromJson(reader);
                 } else {

sdk/eventhubs/azure-resourcemanager-eventhubs/src/main/java/com/azure/resourcemanager/eventhubs/fluent/models/ClusterProperties.java

@@ -53,6 +53,11 @@ public final class ClusterProperties implements JsonSerializable<ClusterProperti
      */
     private PlatformCapabilities platformCapabilities;
 
+    /*
+     * A value that indicates whether the cluster is zone redundant.
+     */
+    private Boolean zoneRedundant;
+
     /**
      * Creates an instance of ClusterProperties class.
      */
@@ -145,6 +150,26 @@ public ClusterProperties withPlatformCapabilities(PlatformCapabilities platformC
         return this;
     }
 
+    /**
+     * Get the zoneRedundant property: A value that indicates whether the cluster is zone redundant.
+     * 
+     * @return the zoneRedundant value.
+     */
+    public Boolean zoneRedundant() {
+        return this.zoneRedundant;
+    }
+
+    /**
+     * Set the zoneRedundant property: A value that indicates whether the cluster is zone redundant.
+     * 
+     * @param zoneRedundant the zoneRedundant value to set.
+     * @return the ClusterProperties object itself.
+     */
+    public ClusterProperties withZoneRedundant(Boolean zoneRedundant) {
+        this.zoneRedundant = zoneRedundant;
+        return this;
+    }
+
     /**
      * Validates the instance.
      * 
@@ -164,6 +189,7 @@ public JsonWriter toJson(JsonWriter jsonWriter) throws IOException {
         jsonWriter.writeStartObject();
         jsonWriter.writeBooleanField("supportsScaling", this.supportsScaling);
         jsonWriter.writeJsonField("platformCapabilities", this.platformCapabilities);
+        jsonWriter.writeBooleanField("zoneRedundant", this.zoneRedundant);
         return jsonWriter.writeEndObject();
     }
 
@@ -196,6 +222,8 @@ public static ClusterProperties fromJson(JsonReader jsonReader) throws IOExcepti
                     deserializedClusterProperties.supportsScaling = reader.getNullable(JsonReader::getBoolean);
                 } else if ("platformCapabilities".equals(fieldName)) {
                     deserializedClusterProperties.platformCapabilities = PlatformCapabilities.fromJson(reader);
+                } else if ("zoneRedundant".equals(fieldName)) {
+                    deserializedClusterProperties.zoneRedundant = reader.getNullable(JsonReader::getBoolean);
                 } else {
                     reader.skipChildren();
                 }