I am trying to use kafka-streams (I know it isn’t released yet but seems to be fairly far on in its implementation and I would like to use that rather than samza for this project as my project doesn’t need to go live yet). My set up has a single source, producer, in memory state store and sink. The state store is called local-state. I can see that there is a kafka topic created which does contain my state and the topic name is the same as the state store name. When I stop and restart the kafka stream code, it restores the state from a topic with a name from a call to storeChangelogTopic(jobId, storeName), there is a topic that exists with this name but it doesn’t have the state in it, the state is in a topic called storeName. If I change the code so it restores from changeName it works fine. Am I doing something wrong and if so any pointers as to what I should do.
Thanks.
