Hi Guozhang, I have created a ticket for this issue:
KAFKA-3207 <https://issues.apache.org/jira/browse/KAFKA-3207> Thanks, Tom > On 4 Feb 2016, at 08:54, Tom Dearman <tom.dear...@gmail.com> wrote: > > Guozhang, > > I will do that now, thanks. > It looks like it is just due to StoreChangeLogger getting its topic value > direct from the store suppliers name which is just the [store-name]. > > Tom > >> On 3 Feb 2016, at 23:57, Guozhang Wang <wangg...@gmail.com> wrote: >> >> Thanks for letting me know. From what you said it seems a bug in the Kafka >> Streams, would you like to create JIRA with your topology code? I'll start >> the investigation right away. >> >> Guozhang >> >> On Wed, Feb 3, 2016 at 3:45 PM, Tom Dearman <tom.dear...@gmail.com> wrote: >> >>> 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 >>>> >>> >> >> >> >> -- >> -- Guozhang >
