Don't create new broker and producer instances

Before, new broker and producer instances were created for each
substream and immediately replaced with the instances stored in the
application object.
The large amount of new instances is unnecessary and triggered a
resource leak in the Python broker wrapper.
1 job for avoid_new_broker_instances in 36 seconds