diff --git a/src/KafkaFlow/Consumers/ConsumerWorker.cs b/src/KafkaFlow/Consumers/ConsumerWorker.cs
index eba54afca..03829166f 100644
--- a/src/KafkaFlow/Consumers/ConsumerWorker.cs
+++ b/src/KafkaFlow/Consumers/ConsumerWorker.cs
@@ -162,6 +162,7 @@ private async Task ProcessMessageAsync(IMessageContext context, CancellationToke
                     {
                         context.Message,
                         context.ConsumerContext.Topic,
+                        context.ConsumerContext.TopicPartitionOffset,
                         MessageKey = context.Message.Key,
                         context.ConsumerContext.ConsumerName,
                     });