chore: include message offset into logs (#157)

chore: include message offset into logs

Author: AlexeyRaga

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
             }
         }
     }
-}
+}

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
             }
         }
     }
-}
+}

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
             }
         }
     }
-}
+}