Ruslan-Droid

I'm trying to run the PushBasedJetStreamBroker as shown in the example. But when I run the main python file, I get an error - **"consumer name already in use"** My...

When we start worker and code with broker that using streams it trying to create new stream every time. Added check if stream created. If not it will be created