diff --git a/src/KafkaFlow/Consumers/ConsumerWorker.cs b/src/KafkaFlow/Consumers/ConsumerWorker.cs
index 8e60861c5..a40f2143a 100644
--- a/src/KafkaFlow/Consumers/ConsumerWorker.cs
+++ b/src/KafkaFlow/Consumers/ConsumerWorker.cs
@@ -131,7 +131,7 @@ private async Task ProcessMessageAsync(IMessageContext context, CancellationToke
                 {
                     await this.globalEvents.FireMessageConsumeStartedAsync(new MessageEventContext(context));
 
-                    await context.ConsumerContext.Completion.ContinueWith(
+                    _= context.ConsumerContext.Completion.ContinueWith(
                         async task =>
                         {
                             if (task.IsFaulted)
@@ -145,8 +145,6 @@ await context.ConsumerContext.Completion.ContinueWith(
                     await this.middlewareExecutor
                         .Execute(context, _ => Task.CompletedTask)
                         .ConfigureAwait(false);
-
-                    await this.globalEvents.FireMessageConsumeCompletedAsync(new MessageEventContext(context));
                 }
                 catch (OperationCanceledException) when (cancellationToken.IsCancellationRequested)
                 {