From 0436794e8ec73e3668d81cda897f3cbb16c6645b Mon Sep 17 00:00:00 2001 From: masesdevelopers <94312179+masesdevelopers@users.noreply.github.com> Date: Wed, 18 Oct 2023 01:57:23 +0200 Subject: [PATCH] Fix programs --- tests/KNetCompactedReplicatorTest/Program.cs | 6 +++--- tests/KNetTest/Program.cs | 4 ++-- 2 files changed, 5 insertions(+), 5 deletions(-) diff --git a/tests/KNetCompactedReplicatorTest/Program.cs b/tests/KNetCompactedReplicatorTest/Program.cs index f39f1b5955..17a9014c48 100644 --- 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(), + ValueSerDes = new JsonSerDes.Value(), }) { 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(), + ValueSerDes = new JsonSerDes.Value(), }) { 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(), + ValueSerDes = new JsonSerDes.Value(), }) { replicator.StartAndWait(); diff --git a/tests/KNetTest/Program.cs b/tests/KNetTest/Program.cs index 0cd37b7c43..b6ff62ec73 100644 --- a/tests/KNetTest/Program.cs +++ b/tests/KNetTest/Program.cs @@ -180,7 +180,7 @@ static void ProduceSomething() .ToProperties(); KNetSerDes keySerializer = new KNetSerDes(); - JsonSerDes valueSerializer = new JsonSerDes(); + JsonSerDes.Value valueSerializer = new JsonSerDes.Value(); try { using (var producer = new KNetProducer(props, keySerializer, valueSerializer)) @@ -248,7 +248,7 @@ static void ConsumeSomething() .ToProperties(); KNetSerDes keyDeserializer = new KNetSerDes(); - KNetSerDes valueDeserializer = new JsonSerDes(); + KNetSerDes valueDeserializer = new JsonSerDes.Value(); ConsumerRebalanceListener rebalanceListener = null; KNetConsumer consumer = null;