Hi Damian, > > Failed to read key hello, org.mkhq.kafka.Topology$StoreUnavailable > > > Failed to read key hello, org.mkhq.kafka.Topology$KeyNotFound > > > hello -> 10 > > > > > The case where you get KeyNotFound looks like a bug to me. This shouldn't > happen. I can see why it might happen and we will create a JIRA and fix it > right away. >
Great, thanks for looking into this. I'll try again once the PR is merged. > > I'm not sure how you end up with (hello -> 10). It could indicate that the > offsets for the topic you are consuming from weren't committed so the data > gets processed again on the restart. > Yes, it didn't commit the offsets since streams.close() was not called on ctrl-c. Fixed by adding a shutdown hook. Thanks, Mikael > Thanks, > Damian >
