}
>
> protected static Uplink deserialize(String json) {
> try {
> return objectMapper.readValue(json, Uplink.class);
> } catch (IOException e) {
> System.out.println(e.getMessage());
> return new Uplink().setOperatorI
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 thi
essage());
return new
Stat().setOperatorId("fake").setNetworkPartnerId("fake").setBaseStationId("fake").setTimestamp(System.currentTimeMillis()).setCount(-1L);
}
}
protected static String serializeStat(Stat stat) {
try {
String s
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 kafka-stream application.
>
> I
Good morning,
I have a problem with a kafka-stream application.
In fact I 've created already two kafka stream applications :
StatsByMinute : entry topic : uplinks, out topic : statsM.
StatsByHour : entrey topic : statsM, out topic : statsH.
StatsByDay : entry topic : statsH, out topic : stats
