Currently, when working with Kafka backed state stores in Kafka Streams, these log compacted topics are given a hardcoded name : app_id-storename-changelog
MirrorMaker2(mm2) copies these topics to remote cluster under the name src-cluster-alias.app_id-storename-changelog
When streams app fails over to the remote cluster it has troubles to find changelog topic of its state store since it was renamed - given source cluster prefix by mm2.
Whats the fix should be ? instruct mm2 to keep topic name or subscribe to regex *.app_id-storename-changelog topic name for the state's changelog.