### Question:
MemcachedBucketConfig extends AbstractBucketConfig { public SortedMap<Long, NodeInfo> ketamaNodes() { return ketamaNodes; } @JsonCreator  MemcachedBucketConfig(
            @JacksonInject("env") CoreEnvironment env,
            @JsonProperty("rev") long rev,
            @JsonProperty("uuid") String uuid,
            @JsonProperty("name") String name,
            @JsonProperty("uri") String uri,
            @JsonProperty("streamingUri") String streamingUri,
            @JsonProperty("nodes") List<NodeInfo> nodeInfos,
            @JsonProperty("nodesExt") List<PortInfo> portInfos,
            @JsonProperty("bucketCapabilities") List<BucketCapabilities> bucketCapabilities,
            @JsonProperty("clusterCapabilities") Map<String, Set<ClusterCapabilities>> clusterCapabilities,
            @JacksonInject("origin") String origin); @Override boolean tainted(); @Override long rev(); @Override BucketType type(); SortedMap<Long, NodeInfo> ketamaNodes(); NodeIdentifier nodeForId(final byte[] id); @Override boolean hasFastForwardMap(); @Override String toString(); @Override boolean equals(Object o); @Override int hashCode();  }### Answer:
@Test void shouldOnlyTakeNodesArrayIntoAccount() { MemcachedBucketConfig config = readConfig("memcached_during_rebalance.json"); List<String> mustContain = Arrays.asList( "10.0.0.1", "10.0.0.2", "10.0.0.3" ); List<String> mustNotContain = Collections.singletonList("10.0.0.4"); Collection<NodeInfo> actualRingNodes = config.ketamaNodes().values(); for (NodeInfo nodeInfo : actualRingNodes) { String actual = nodeInfo.hostname(); assertTrue(mustContain.contains(actual)); assertFalse(mustNotContain.contains(actual)); } }