Re: Error kafka-stream method punctuate in context.forward()

2016-09-22 Thread Guozhang Wang
} finally { > context.commit(); > } > } > > @Override > public void close() { > this.kvStore.close(); > } > > protected static Uplink deserialize(String json) { > try { > return objectMapper.readValue(json, U

RE: Error kafka-stream method punctuate in context.forward()

2016-09-20 Thread Hamza HACHANI
I'm using the version 10.0 De : Hamza HACHANI Envoyé : lundi 19 septembre 2016 19:20:23 À : users@kafka.apache.org Objet : RE: Error kafka-stream method punctuate in context.forward() Hi Guozhang, Here is the code for the two concerned classes If this can

RE: Error kafka-stream method punctuate in context.forward()

2016-09-20 Thread Hamza HACHANI
illis()).setCount(-1L); } } protected static String serializeStat(Stat stat) { try { String s = objectMapper.writeValueAsString(stat); return s; } catch (IOException e) { System.out.println(e.getMessage()); return

Re: Error kafka-stream method punctuate in context.forward()

2016-09-19 Thread Guozhang Wang
Hello Hamza, Which Kafka version are you using with this application? Also could you share your code skeleton of the StatsByDay processor implementation? Guozhang On Fri, Sep 16, 2016 at 6:58 AM, Hamza HACHANI wrote: > Good morning, > > I have a problem with a