public synchronized Throwable nextError(final String topologyName) {
            return newErrorsByTopology.containsKey(topologyName) ?
                newErrorsByTopology.get(topologyName).poll() :
                null;
        }
@return  true iff all fields other than {@link StreamsMetadataImpl#topologyName()}
         match between the two StreamsMetadata objects
streams/src/test/java/org/apache/kafka/streams/integration/NamedTopologyIntegrationTest.java