private static void produceToInputTopics(final String topic, final Collection<KeyValue<String, Long>> records) {
        IntegrationTestUtils.produceKeyValuesSynchronously(
            topic,
            records,
            producerConfig,
            CLUSTER.time
        );
    }
@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