Chris Hamons

@BewareMyPower - You looked into another of my issues, maybe you know?

https://github.com/streamnative/pulsar-rs/blob/master/src/connection.rs#L731-L750 is the code I believe we're hitting

I'm a bit confused on the safety of retrying. I first read >It's safe to retry, but it would be better to just configure a big operation timeout. then later:...

@darinspivey - I'd have to see the full logs, but given my current understanding of the issue I was seeing, I pretty strongly suspect they are the same. That connection...

> It doesn't correspond with the time where I saw my consumer getting removed, though. Honestly, there's probably a few issues around making sure partitioned topics stay correctly connected, so...

I am looking into how difficult this would be to fix, and I have a [unit test](https://github.com/chamons/pulsar-rs/blob/9ddce8871129298a89d7a1867d457f88bbf20d06/src/consumer/mod.rs#L1318-L1414) that I think shows the same behavior. I don't see all of the...

Ok, it looks like my original potential unit test yesterday doesn't fail for the reason I think it did. It fails due to another bug, this one in the producer:...

Ok, after looking into this more, it seems like my load shed example itself ran into the [Topic load shedding causes Producers (including built in one in connection object) to...

I've updated the title and description, as I am no longer certain at all if load shedding can trigger this issue. It can absolutely cause https://github.com/streamnative/pulsar-rs/issues/378 which is what my...

Update on my update 1 hour ago, I have it pinned down to the specific lines of code. It appears in some error conditions your MultiTopicConsumer gets topics removed from...