class KafkaStreams implements AutoCloseable {

    public Collection<StreamsMetadata> allMetadataForStore(final String storeName) {
        validateIsRunningOrRebalancing();
        return streamsMetadataState.getAllMetadataForStore(storeName);
    }

    public  KafkaStreams(final Topology topology,
                        final Properties props);
    public  KafkaStreams(final Topology topology,
                        final Properties props,
                        final KafkaClientSupplier clientSupplier);
    public  KafkaStreams(final Topology topology,
                        final Properties props,
                        final Time time);
    public  KafkaStreams(final Topology topology,
                        final Properties props,
                        final KafkaClientSupplier clientSupplier,
                        final Time time);
    @Deprecated public  KafkaStreams(final Topology topology,
                        final StreamsConfig config);
    @Deprecated public  KafkaStreams(final Topology topology,
                        final StreamsConfig config,
                        final KafkaClientSupplier clientSupplier);
    @Deprecated public  KafkaStreams(final Topology topology,
                        final StreamsConfig config,
                        final Time time);
    private  KafkaStreams(final InternalTopologyBuilder internalTopologyBuilder,
                         final StreamsConfig config,
                         final KafkaClientSupplier clientSupplier);
    private  KafkaStreams(final InternalTopologyBuilder internalTopologyBuilder,
                         final StreamsConfig config,
                         final KafkaClientSupplier clientSupplier,
                         final Time time);

}