Fabio Labella

I actually write Kafka code on top of fs2-kafka very differently, the interface I expose is `(Chunk[A] => F[Chunk[B]]): F[Unit]`, and both ConsumerRecords and `Stream` are hidden, for various reasons....

> By the way, if there exists a better way to implement this kind of behavior, I would be glad to know about it. I didn't 100% understand the use...

Ah, partially related: if you have a minimised example of the sort of behaviour you are trying to express with `observe`, I can have a look as to whether there...

But the `Scope` one is more worrying tbh (for that case I'd check with the newest version though)

Well I'm about to reimplement `broadcastThrough` anyway (and remove `broadcast` and `Broadcast`). I do wonder why the performance has changed, I don't think we've touched it yet, maybe it's just...

``` val executor = Executors.newSingleThreadExecutor ``` mmm

@nikiforo The reason I commented that is that a large amount of Cats Effect 3 performance improvements (in real world scenarios, not just flatMap loops) is due to its new...

As explained in the chat, this is due to the fact that publishing to a Topic (which backs `broadcastThrough`) is not atomic, but rather it enqueues the same elements to...

What do you mean by raceThrough? If you mean something that relaxes backpressure so that pipes can run ahead, you can do it by using prefetch on the pipes, you...

> As an approximation, perhaps we could allow to configure the number of "look-ahead" elements in the topic? There is a "1" hardcoded in the source code of broadcastThrough @diesalbla...