avro -> v1.7.7.6. fix+expand on tests (#795)

Author: mhowlett

src/Confluent.SchemaRegistry.Serdes/Confluent.SchemaRegistry.Serdes.csproj

@@ -20,7 +20,7 @@
   </PropertyGroup>
 
   <ItemGroup>
-    <PackageReference Include="Confluent.Apache.Avro" Version="1.7.7.5" />
+    <PackageReference Include="Confluent.Apache.Avro" Version="1.7.7.6" />
     <PackageReference Include="Newtonsoft.Json" Version="9.0.1" />
   </ItemGroup>
 

test/Confluent.SchemaRegistry.Serdes.IntegrationTests/Tests/AutoRegisterSchemaDisabled.cs

@@ -63,14 +63,30 @@ public static void AutoRegisterSchemaDisabled(string bootstrapServers, string sc
                 {
                     Assert.Throws<SerializationException>(() =>
                     {
+                        string guidTopic = new Guid().ToString();
                         try
                         {
                             producer
-                                .ProduceAsync(new Guid().ToString(), new Message<string, int> { Key = "test", Value = 112 })
-                                .Wait();
+                                .ProduceAsync(guidTopic, new Message<string, int> { Key = "test", Value = 112 })
+                                .GetAwaiter()
+                                .GetResult();
                         }
-                        catch (AggregateException e)
+                        catch (Exception e)
                         {
+                            Assert.True(e is ProduceException<string, int>);
+                            Assert.Equal(ErrorCode.Local_ValueSerialization, ((ProduceException<string, int>)e).Error.Code);
+
+                            // Test message fields are appropriately set in the case of a serialization error.
+                            Assert.Equal("test", ((ProduceException<string, int>)e).DeliveryResult.Key);
+                            Assert.Equal(112, ((ProduceException<string, int>)e).DeliveryResult.Value);
+                            Assert.Equal(Offset.Invalid, ((ProduceException<string, int>)e).DeliveryResult.Offset);
+                            Assert.Equal(Partition.Any, ((ProduceException<string, int>)e).DeliveryResult.Partition);
+                            Assert.Equal(guidTopic, ((ProduceException<string, int>)e).DeliveryResult.Topic);
+                            Assert.Equal(PersistenceStatus.NotPersisted, ((ProduceException<string, int>)e).DeliveryResult.PersistenceStatus);
+                            Assert.Equal(Timestamp.Default, ((ProduceException<string, int>)e).DeliveryResult.Timestamp);
+                            Assert.Null(((ProduceException<string, int>)e).DeliveryResult.Headers);
+
+                            // should be SerializationException.
                             throw e.InnerException;
                         }
                     });
@@ -89,10 +105,13 @@ public static void AutoRegisterSchemaDisabled(string bootstrapServers, string sc
                     {
                         try
                         {
-                            producer.ProduceAsync(topic.Name, new Message<string, int> { Key = "test", Value = 112 }).Wait();
+                            producer.ProduceAsync(topic.Name, new Message<string, int> { Key = "test", Value = 112 })
+                                .GetAwaiter()
+                                .GetResult();
                         }
-                        catch (AggregateException e)
+                        catch (Exception e)
                         {
+                            Assert.True(e is ProduceException<string, int>);
                             throw e.InnerException;
                         }
                     });

test/Confluent.SchemaRegistry.Serdes.IntegrationTests/Tests/ProduceIncompatibleTypes.cs

@@ -77,10 +77,12 @@ public static void ProduceIncompatibleTypes(string bootstrapServers, string sche
                     {
                         producer
                             .ProduceAsync(topic, new Message<int, string> { Key = 42, Value = "world" })
-                            .Wait();
+                            .GetAwaiter()
+                            .GetResult();
                     }
-                    catch (AggregateException e)
+                    catch (Exception e)
                     {
+                        Assert.True(e is ProduceException<int, string>);
                         throw e.InnerException;
                     }
                 });
@@ -99,10 +101,12 @@ public static void ProduceIncompatibleTypes(string bootstrapServers, string sche
                     {
                         producer
                             .ProduceAsync(topic, new Message<string, int> { Key = "world", Value = 42 })
-                            .Wait();
+                            .GetAwaiter()
+                            .GetResult();
                     }
-                    catch (AggregateException e)
+                    catch (Exception e)
                     {
+                        Assert.True(e is ProduceException<string, int>);
                         throw e.InnerException;
                     }
                 });