fix: new serialization extension methods

Farfetch · Oct 25, 2023 · 3775633 · 3775633
1 parent 896a256
commit 3775633
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/src/KafkaFlow.IntegrationTests/GlobalEventsTest.cs b/src/KafkaFlow.IntegrationTests/GlobalEventsTest.cs
@@ -222,7 +222,7 @@ private void ConfigureConsumer<T>(IConsumerConfigurationBuilder consumerConfigur
                 .WithAutoOffsetReset(KafkaFlow.AutoOffsetReset.Earliest)
                 .AddMiddlewares(
                     middlewares => middlewares
-                        .AddSerializer<ProtobufNetSerializer>()
+                        .AddDeserializer<ProtobufNetDeserializer>()
                         .Add<T>())
                 .WithPartitionsAssignedHandler((_, _) =>
                 {

diff --git a/src/KafkaFlow.IntegrationTests/OpenTelemetryTests.cs b/src/KafkaFlow.IntegrationTests/OpenTelemetryTests.cs
@@ -150,7 +150,7 @@ private async Task<IServiceProvider> GetServiceProvider()
                                             .WithAutoOffsetReset(AutoOffsetReset.Latest)
                                             .AddMiddlewares(
                                                 middlewares => middlewares
-                                                    .AddCompressor<GzipMessageCompressor>()
+                                                    .AddDecompressor<GzipMessageDecompressor>()
                                                     .Add<GzipMiddleware>())
                                             .WithPartitionsAssignedHandler((_, _) =>
                                             {