Support multiple brokers - create one consumer per broker