class StreamsMetadataState {

    public StreamsMetadata getLocalMetadata() {
        return localMetadata.get();
    }

    public  StreamsMetadataState(final InternalTopologyBuilder builder, final HostInfo thisHost);

}