Description
Currently, when working with Kafka backed state stores in Kafka Streams, these log compacted topics are given a hardcoded name : my.app.id-storename-changelog
public static String storeChangelogTopic(String applicationId, String storeName) { return applicationId + "-" + storeName + STATE_CHANGELOG_TOPIC_SUFFIX; }
It would be nice if somehow I would be able to override this functionality and provide the topic-name myself when creating the state-store.
Any comments?
Would it be OK to submit a PR for this?