} finally {
> context.commit();
> }
> }
>
> @Override
> public void close() {
> this.kvStore.close();
> }
>
> protected static Uplink deserialize(String json) {
> try {
> return objectMapper.readValue(json, U
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
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
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