Update Schema Registry API to include protobuf (Azure#36559)

* Update README to use latest.

* Regenerate from autorest.

* Update assets.json

* update changelog.

Author: conniey

sdk/schemaregistry/azure-data-schemaregistry/CHANGELOG.md

@@ -4,6 +4,8 @@
 
 ### Features Added
 
+- Add support for protobuf schema format.
+
 ### Breaking Changes
 
 ### Bugs Fixed

sdk/schemaregistry/azure-data-schemaregistry/assets.json

@@ -2,5 +2,5 @@
   "AssetsRepo": "Azure/azure-sdk-assets",
   "AssetsRepoPrefixPath": "java",
   "TagPrefix": "java/schemaregistry/azure-data-schemaregistry",
-  "Tag": "java/schemaregistry/azure-data-schemaregistry_11bc411368"
+  "Tag": "java/schemaregistry/azure-data-schemaregistry_1eb85e2a8b"
 }

sdk/schemaregistry/azure-data-schemaregistry/src/main/java/com/azure/data/schemaregistry/implementation/AzureSchemaRegistryImpl.java

@@ -6,7 +6,6 @@
 
 import com.azure.core.http.HttpPipeline;
 import com.azure.core.http.HttpPipelineBuilder;
-import com.azure.core.http.policy.CookiePolicy;
 import com.azure.core.http.policy.RetryPolicy;
 import com.azure.core.http.policy.UserAgentPolicy;
 import com.azure.core.util.serializer.JacksonAdapter;
@@ -94,9 +93,7 @@ public SchemasImpl getSchemas() {
      */
     AzureSchemaRegistryImpl(String endpoint, String apiVersion) {
         this(
-                new HttpPipelineBuilder()
-                        .policies(new UserAgentPolicy(), new RetryPolicy(), new CookiePolicy())
-                        .build(),
+                new HttpPipelineBuilder().policies(new UserAgentPolicy(), new RetryPolicy()).build(),
                 JacksonAdapter.createDefaultSerializerAdapter(),
                 endpoint,
                 apiVersion);

sdk/schemaregistry/azure-data-schemaregistry/src/main/java/com/azure/data/schemaregistry/implementation/AzureSchemaRegistryImplBuilder.java

@@ -17,7 +17,6 @@
 import com.azure.core.http.policy.AddDatePolicy;
 import com.azure.core.http.policy.AddHeadersFromContextPolicy;
 import com.azure.core.http.policy.AddHeadersPolicy;
-import com.azure.core.http.policy.CookiePolicy;
 import com.azure.core.http.policy.HttpLogOptions;
 import com.azure.core.http.policy.HttpLoggingPolicy;
 import com.azure.core.http.policy.HttpPipelinePolicy;
@@ -217,11 +216,11 @@ public AzureSchemaRegistryImplBuilder retryPolicy(RetryPolicy retryPolicy) {
     @Generated
     public AzureSchemaRegistryImpl buildClient() {
         HttpPipeline localPipeline = (pipeline != null) ? pipeline : createHttpPipeline();
-        String localApiVersion = (apiVersion != null) ? apiVersion : "2022-10";
+        String localApiVersion = (apiVersion != null) ? apiVersion : "2023-07-01";
         SerializerAdapter localSerializerAdapter =
                 (serializerAdapter != null) ? serializerAdapter : JacksonAdapter.createDefaultSerializerAdapter();
         AzureSchemaRegistryImpl client =
-                new AzureSchemaRegistryImpl(localPipeline, localSerializerAdapter, endpoint, localApiVersion);
+                new AzureSchemaRegistryImpl(localPipeline, localSerializerAdapter, this.endpoint, localApiVersion);
         return client;
     }
 
@@ -249,7 +248,6 @@ private HttpPipeline createHttpPipeline() {
         HttpPolicyProviders.addBeforeRetryPolicies(policies);
         policies.add(ClientBuilderUtil.validateAndGetRetryPolicy(retryPolicy, retryOptions, new RetryPolicy()));
         policies.add(new AddDatePolicy());
-        policies.add(new CookiePolicy());
         this.pipelinePolicies.stream()
                 .filter(p -> p.getPipelinePosition() == HttpPipelinePosition.PER_RETRY)
                 .forEach(p -> policies.add(p));

sdk/schemaregistry/azure-data-schemaregistry/src/main/java/com/azure/data/schemaregistry/implementation/SchemasImpl.java

@@ -249,7 +249,7 @@ Response<SchemaVersions> getVersionsNextSync(
     @ServiceMethod(returns = ReturnType.SINGLE)
     public Mono<ResponseBase<SchemasGetByIdHeaders, Flux<ByteBuffer>>> getByIdWithResponseAsync(String id) {
         final String accept =
-                "application/json; serialization=Avro, application/json; serialization=json, text/plain; charset=utf-8";
+                "application/json; serialization=Avro, application/json; serialization=json, text/plain; charset=utf-8, text/vnd.ms.protobuf";
         return FluxUtil.withContext(
                 context ->
                         service.getById(this.client.getEndpoint(), id, this.client.getApiVersion(), accept, context));
@@ -273,7 +273,7 @@ public Mono<ResponseBase<SchemasGetByIdHeaders, Flux<ByteBuffer>>> getByIdWithRe
     public Mono<ResponseBase<SchemasGetByIdHeaders, Flux<ByteBuffer>>> getByIdWithResponseAsync(
             String id, Context context) {
         final String accept =
-                "application/json; serialization=Avro, application/json; serialization=json, text/plain; charset=utf-8";
+                "application/json; serialization=Avro, application/json; serialization=json, text/plain; charset=utf-8, text/vnd.ms.protobuf";
         return service.getById(this.client.getEndpoint(), id, this.client.getApiVersion(), accept, context);
     }
 
@@ -328,7 +328,7 @@ public Mono<Flux<ByteBuffer>> getByIdAsync(String id, Context context) {
     @ServiceMethod(returns = ReturnType.SINGLE)
     public ResponseBase<SchemasGetByIdHeaders, BinaryData> getByIdWithResponse(String id, Context context) {
         final String accept =
-                "application/json; serialization=Avro, application/json; serialization=json, text/plain; charset=utf-8";
+                "application/json; serialization=Avro, application/json; serialization=json, text/plain; charset=utf-8, text/vnd.ms.protobuf";
         return service.getByIdSync(this.client.getEndpoint(), id, this.client.getApiVersion(), accept, context);
     }
 
@@ -581,7 +581,7 @@ public PagedIterable<Integer> getVersions(String groupName, String schemaName, C
     public Mono<ResponseBase<SchemasGetSchemaVersionHeaders, Flux<ByteBuffer>>> getSchemaVersionWithResponseAsync(
             String groupName, String schemaName, int schemaVersion) {
         final String accept =
-                "application/json; serialization=Avro, application/json; serialization=json, text/plain; charset=utf-8";
+                "application/json; serialization=Avro, application/json; serialization=json, text/plain; charset=utf-8, text/vnd.ms.protobuf";
         return FluxUtil.withContext(
                 context ->
                         service.getSchemaVersion(
@@ -614,7 +614,7 @@ public Mono<ResponseBase<SchemasGetSchemaVersionHeaders, Flux<ByteBuffer>>> getS
     public Mono<ResponseBase<SchemasGetSchemaVersionHeaders, Flux<ByteBuffer>>> getSchemaVersionWithResponseAsync(
             String groupName, String schemaName, int schemaVersion, Context context) {
         final String accept =
-                "application/json; serialization=Avro, application/json; serialization=json, text/plain; charset=utf-8";
+                "application/json; serialization=Avro, application/json; serialization=json, text/plain; charset=utf-8, text/vnd.ms.protobuf";
         return service.getSchemaVersion(
                 this.client.getEndpoint(),
                 groupName,
@@ -686,7 +686,7 @@ public Mono<Flux<ByteBuffer>> getSchemaVersionAsync(
     public ResponseBase<SchemasGetSchemaVersionHeaders, BinaryData> getSchemaVersionWithResponse(
             String groupName, String schemaName, int schemaVersion, Context context) {
         final String accept =
-                "application/json; serialization=Avro, application/json; serialization=json, text/plain; charset=utf-8";
+                "application/json; serialization=Avro, application/json; serialization=json, text/plain; charset=utf-8, text/vnd.ms.protobuf";
         return service.getSchemaVersionSync(
                 this.client.getEndpoint(),
                 groupName,

sdk/schemaregistry/azure-data-schemaregistry/swagger/README.md

@@ -16,7 +16,8 @@ autorest --java --use:@autorest/java@4.0.x
 
 ### Code generation settings
 ```yaml
-input-file: https://raw.githubusercontent.com/Azure/azure-rest-api-specs/19aa8ab5d14b22bdeb67eab31c65b47c5380fd06/specification/schemaregistry/data-plane/Microsoft.EventHub/stable/2022-10/schemaregistry.json
+use: '@autorest/java@4.1.19'
+input-file: https://github.com/Azure/azure-rest-api-specs/blob/84d7b8f05a60d12922341578434b512540563850/specification/schemaregistry/data-plane/Microsoft.EventHub/stable/2023-07-01/schemaregistry.json
 java: true
 output-folder: ../
 namespace: com.azure.data.schemaregistry