How to limit the maximum number of messages for all consumers on a single client

[wf-soft]

I am currently using SemanticSlim to limit concurrency, but I may face message timeout and redelivery issues. Is there a better way

var sm = new SemaphoreSlim(10, 64);
_=Task.Factory.StartNew(async() =>
{
    await foreach (var msg in c.ConsumeAsync<string>())
    {
        try
        {
            await sm.WaitAsync();
            Console.WriteLine($"[1]：{msg.Data}");
            await msg.AckAsync();
        }
        finally
        {
            sm.Release();
        }
    }
}, TaskCreationOptions.LongRunning);

_ = Task.Factory.StartNew(async () =>
{
    await foreach (var msg in c2.ConsumeAsync<string>())
    {
        try
        {
            await sm.WaitAsync();
            Console.WriteLine($"[2]：{msg.Data}");
            await msg.AckAsync();
        }
        finally
        {
            sm.Release();
        }
    }
}, TaskCreationOptions.LongRunning);

[mtmk]

that sounds sensible to me. you might also want to experiment with consume options. by default it fetches messages in batches of 1000 for example. That option is called MaxMsgs. reducing that should help.