MassTransit + EventHub with own message format

{
  "Type": "ExampleMessage"
}

var builder = Host.CreateApplicationBuilder();
builder.Services
    .AddMassTransit(x =>
    {
        x.UsingInMemory();
        x.AddRider(rider =>
        {
            rider.AddConsumer<EventHubMessageConsumer>();

            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<EventHubMessageConsumer>(context);
                });
            });
        });
    });

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

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

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