Change so generic data sink uses case insensitive property names (#345)

koralium · Jan 31, 2024 · 3bb71bd · 3bb71bd
1 parent 097ab74
commit 3bb71bd
Showing 1 changed file with 4 additions and 1 deletion.
diff --git a/src/FlowtideDotNet.Core/Sources/Generic/Internal/GenericWriteOperator.cs b/src/FlowtideDotNet.Core/Sources/Generic/Internal/GenericWriteOperator.cs
@@ -70,7 +70,10 @@ private async IAsyncEnumerable<FlowtideGenericWriteObject<T>> ChangesToGeneric(I
                 using var memoryStream = new MemoryStream();
                 streamEventToJson.Write(memoryStream, row.Row);
                 memoryStream.Position = 0;
-                var obj = JsonSerializer.Deserialize<T>(memoryStream);
+                var obj = JsonSerializer.Deserialize<T>(memoryStream, new JsonSerializerOptions()
+                {
+                    PropertyNameCaseInsensitive = true
+                });
                 if (obj == null)
                 {
                     throw new InvalidOperationException("Could not convert row to generic object");