public static String storeChangelogTopic(final String prefix, final String storeName, final String namedTopology) {
        if (namedTopology == null) {
            return prefix + "-" + storeName + STATE_CHANGELOG_TOPIC_SUFFIX;
        } else {
            return prefix + "-" + namedTopology + "-" + storeName + STATE_CHANGELOG_TOPIC_SUFFIX;
        }
    }
@Test
    public void shouldReturnDefaultChangelogTopicNameWithNamedTopology() {
        final String applicationId = "appId";
        final String namedTopology = "namedTopology";
        final String storeName = "store";

        assertThat(
            ProcessorStateManager.storeChangelogTopic(applicationId, storeName, namedTopology),
            is(applicationId + "-" + namedTopology + "-" + storeName + "-changelog")
        );
    }