 	let nodeId: ReplicaId
 
     lazy var dispatchQueue: DispatchQueue = {
-        return DispatchQueue(
-            label: "metadata.cluster.read.stream.franz",
-            attributes: []
-        )
+        return DispatchQueue(label: "metadata.cluster.read.stream.franz")
     }()
-    
-    ///Used for swapping in fake brokers during testing
-	private var _brokers = [String: Broker]()
-    internal var brokers: [Broker] {
-        get {
-            return Array(_brokers.values)
-        }
-        set {
-            _brokers = [String: Broker]()
-            for broker in newValue {
-                _brokers["\(broker.host):\(broker.port)"] = broker
-            }
-        }
-    }
+	
+	private var brokers = [String: Broker]()
     
     /**
         Create a new cluster

        - Parameter callback:
     */
    public func listGroups(_ callback: @escaping (String, String) -> ()) {
        for (_, broker) in _brokers {
            dispatchQueue.async {
                broker.listGroups() { a, b in
                    callback(a, b)

        - Parameter callback:
     */
    public func listTopics(_ callback: @escaping ([Topic]) -> ()) {
		self.brokers.first?.value.getTopicMetadata { response in
			var topics = [Topic]()
			for (name, topic) in response.topics {
				var partitions = [PartitionId]()
