MassTransit Kafka Rider 获取原始消息

Question

我需要获取发送到 kafka 进行日志记录的原始消息。 例如，如果验证 context.Message 失败。

我试过这个 的答案，但它不起作用并且 context.TryGetMessage<JToken>() return 一直都是 null。

Answer 1

Confluent.Kafka 客户端不公开原始消息数据，仅公开反序列化的消息类型。因此，MassTransit 没有可访问的消息正文。