brokers leak because of exception at broker.flush call