feat: support MessageBody on ReceiveContext for Kafka Transport

RJSonnenberg · May 22, 2023 · f9510ec · f9510ec
1 parent a4a7337
commit f9510ec
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/src/Transports/MassTransit.KafkaIntegration/KafkaIntegration/KafkaBaseReceiveContext.cs b/src/Transports/MassTransit.KafkaIntegration/KafkaIntegration/KafkaBaseReceiveContext.cs
@@ -22,6 +22,7 @@ public KafkaReceiveContext(ConsumeResult<byte[], byte[]> result, KafkaReceiveEnd
             _result = result;
             _context = context;
 
+            Body = new BytesMessageBody(_result.Message.Value);
             InputAddress = context.GetInputAddress(_result.Topic);
 
             _key = new Lazy<TKey>(() => _context.KeyDeserializer.DeserializeKey(result));
@@ -38,7 +39,7 @@ public KafkaReceiveContext(ConsumeResult<byte[], byte[]> result, KafkaReceiveEnd
 
         protected override IHeaderProvider HeaderProvider => _headerProvider.Value;
 
-        public override MessageBody Body => new NotSupportedMessageBody();
+        public override MessageBody Body { get; }
 
         public string GroupId => _context.GroupId;