I built trunk and pulled source yesterday. There are two topics created one called [store-name] the other as you describe [Job-Id]-[Store-name]-"changelog". Only the one called [store-name] contained the store state, the other topic contained nothing so to get this to work I had to compile the code with the restore from [store-name]. On Wed, 3 Feb 2016, 18:50 Guozhang Wang <wangg...@gmail.com> wrote:
> Hello Tom, > > Thanks for trying out Kafka Streams. A quick question: are you using Kafka > Streams built from trunk? > > In the latest trunk we changed changelog topic name to be the store-name + > "-changelog" suffix. So when your processing job starts the topology > created state should have the topic name as > [Job-Id]-[Store-name]-"changelog". > > Guozhang > > On Wed, Feb 3, 2016 at 7:33 AM, Tom Dearman <tom.dear...@gmail.com> wrote: > > > 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. > > > > > -- > -- Guozhang >
