diff --git a/src/KafkaFlow.Retry/Durable/RetryDurableMiddleware.cs b/src/KafkaFlow.Retry/Durable/RetryDurableMiddleware.cs
index c0efd99e..59dee24c 100644
--- a/src/KafkaFlow.Retry/Durable/RetryDurableMiddleware.cs
+++ b/src/KafkaFlow.Retry/Durable/RetryDurableMiddleware.cs
@@ -85,6 +85,7 @@ public async Task Invoke(IMessageContext context, MiddlewareDelegate next)
                             WaitMilliseconds = waitTime.TotalMilliseconds,
                             PartitionNumber = context.ConsumerContext.Partition,
                             Worker = context.ConsumerContext.WorkerId,
+                            Offset = context.ConsumerContext.Offset,
                             ExceptionType = exception.GetType().FullName,
                             ExceptionMessage = exception.Message
                         });
@@ -151,4 +152,4 @@ await policy
             }
         }
     }
-}
\ No newline at end of file
+}
diff --git a/src/KafkaFlow.Retry/Forever/RetryForeverMiddleware.cs b/src/KafkaFlow.Retry/Forever/RetryForeverMiddleware.cs
index 5725ad27..9190fd49 100644
--- a/src/KafkaFlow.Retry/Forever/RetryForeverMiddleware.cs
+++ b/src/KafkaFlow.Retry/Forever/RetryForeverMiddleware.cs
@@ -58,6 +58,7 @@ public async Task Invoke(IMessageContext context, MiddlewareDelegate next)
                             WaitMilliseconds = waitTime.TotalMilliseconds,
                             PartitionNumber = context.ConsumerContext.Partition,
                             Worker = context.ConsumerContext.WorkerId,
+                            Offset = context.ConsumerContext.Offset,
                             //Headers = context.HeadersAsJson(),
                             //Message = context.Message.ToJson(),
                             ExceptionType = exception.GetType().FullName
@@ -106,4 +107,4 @@ await policy
             }
         }
     }
-}
\ No newline at end of file
+}
diff --git a/src/KafkaFlow.Retry/Simple/RetrySimpleMiddleware.cs b/src/KafkaFlow.Retry/Simple/RetrySimpleMiddleware.cs
index 04ca9af3..a460f4b8 100644
--- a/src/KafkaFlow.Retry/Simple/RetrySimpleMiddleware.cs
+++ b/src/KafkaFlow.Retry/Simple/RetrySimpleMiddleware.cs
@@ -59,6 +59,7 @@ public async Task Invoke(IMessageContext context, MiddlewareDelegate next)
                             WaitMilliseconds = waitTime.TotalMilliseconds,
                             PartitionNumber = context.ConsumerContext.Partition,
                             Worker = context.ConsumerContext.WorkerId,
+                            Offset = context.ConsumerContext.Offset,
                             //Headers = context.HeadersAsJson(),
                             //Message = context.Message.ToJson(),
                             ExceptionType = exception.GetType().FullName
@@ -108,4 +109,4 @@ await policy
             }
         }
     }
-}
\ No newline at end of file
+}