Использование сообщений без конверта из EventHub с помощью MassTransit ⇐ C#

[Anonymous]

У меня есть Azure EventHub с сообщениями без конверта. Это «конверт», но в моем собственном формате. Согласно примерам, которые я вижу в Интернете, это должна быть правильная конфигурация для приема сообщений, не относящихся к MassTransit, но она никогда не доходит до потребителя.
Она проходит через десериализатор необработанного json. Он останавливается на «ConsumeContextMessageTypeFilter», поскольку «выходных каналов» нет...
Пример сообщения:
{
"type": "ExampleMessage",
"data": {}
}

Базовая настройка
var builder = Host.CreateApplicationBuilder();
builder.Services
.AddMassTransit(x =>
{
x.UsingInMemory();
x.AddRider(rider =>
{
rider.AddConsumer();

rider.UsingEventHub((context, k) =>
{
k.Host(
"Endpoint=sb://localhost;SharedAccessKeyName=RootManageSharedAccessKey;SharedAccessKey=SAS_KEY_VALUE;UseDevelopmentEmulator=true;");
k.Storage("UseDevelopmentStorage=true");

k.ReceiveEndpoint("eh1", c =>
{
c.UseRawJsonSerializer(RawSerializerOptions.AnyMessageType, true);
c.ConfigureConsumer(context);
});
});
});
});

var host = builder.Build();
await host.RunAsync();

public class EventHubMessageConsumer :
IConsumer
{
public Task Consume(ConsumeContext context)
{
return Task.CompletedTask;
}
}

public record EventHubMessage
{
public string Type { get; init; }
}


Подробнее здесь: https://stackoverflow.com/questions/793 ... asstransit