Fix #265 (#266)

masesgroup · Oct 18, 2023 · 4d82682 · 4d82682
1 parent bfe14a8
commit 4d82682
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 5 deletions.
diff --git a/tests/KNetCompactedReplicatorTest/Program.cs b/tests/KNetCompactedReplicatorTest/Program.cs
@@ -102,7 +102,7 @@ private static void TestValues(string topicName, int length, UpdateModeTypes typ
                 UpdateMode = type,
                 BootstrapServers = serverToUse,
                 StateName = topicName,
-                ValueSerDes = new JsonSerDes<TestType>(),
+                ValueSerDes = new JsonSerDes.Value<TestType>(),
             })
             {
                 replicator.StartAndWait();
@@ -130,7 +130,7 @@ private static void Test(string topicName, int length, UpdateModeTypes type, int
                 UpdateMode = type,
                 BootstrapServers = serverToUse,
                 StateName = topicName,
-                ValueSerDes = new JsonSerDes<TestType>(),
+                ValueSerDes = new JsonSerDes.Value<TestType>(),
             })
             {
                 replicator.StartAndWait();
@@ -158,7 +158,7 @@ private static void TestOnlyRead(string topicName, int length, UpdateModeTypes t
                 UpdateMode = type,
                 BootstrapServers = serverToUse,
                 StateName = topicName,
-                ValueSerDes = new JsonSerDes<TestType>(),
+                ValueSerDes = new JsonSerDes.Value<TestType>(),
             })
             {
                 replicator.StartAndWait();

diff --git a/tests/KNetTest/Program.cs b/tests/KNetTest/Program.cs
@@ -180,7 +180,7 @@ static void ProduceSomething()
                                                         .ToProperties();
 
                 KNetSerDes<string> keySerializer = new KNetSerDes<string>();
-                JsonSerDes<TestType> valueSerializer = new JsonSerDes<TestType>();
+                JsonSerDes.Value<TestType> valueSerializer = new JsonSerDes.Value<TestType>();
                 try
                 {
                     using (var producer = new KNetProducer<string, TestType>(props, keySerializer, valueSerializer))
@@ -248,7 +248,7 @@ static void ConsumeSomething()
                                                         .ToProperties();
 
                 KNetSerDes<string> keyDeserializer = new KNetSerDes<string>();
-                KNetSerDes<TestType> valueDeserializer = new JsonSerDes<TestType>();
+                KNetSerDes<TestType> valueDeserializer = new JsonSerDes.Value<TestType>();
                 ConsumerRebalanceListener rebalanceListener = null;
                 KNetConsumer<string, TestType> consumer = null;