[PERF] Using the BroadcastHub with thousands of consumers seems painfully slow.

[RollsChris]

Version Information Akka.Streams="1.5.20"

Describe the performance issue I'm trying to create thousands of consumers for a BroadCastHub.

Each consumer listens to the stream and checks if they care about the current item.

As the number increases the performance slows considerably.

We think the buffer plays apart because as soon as we go past the buffer value things get really slow but we are unsure.

We also think that when the buffer gets full there is a potential for it to drop messages, as some values we never see.

Here is a LinqPad URL to demo the issue: LinqPad

Expected behavior Should be able to process 14000 messages across 14000 consumers using a BroadCastHub within seconds

Actual behavior Becomes un-usable in the thousands.

Environment LinqPad demo We are using Linux docker images in product, same performance issue.

[Aaronontheweb]

Thank you for the reproduction! I'll see what we can do here.