untByKey(Serdes.String(), "counted");
> counted.to(Serdes.String(), Serdes.Long(), outputTopic);
>
> Output:
> new KeyValue<>("message1", 1L),
> new KeyValue<>("message1", 2L),
> new KeyValue<>("message2", 1L),
>
L),
new KeyValue<>("message3", 1L),
new KeyValue<>("message4", 1L)
Does that help?
Michael
On Thu, Jun 16, 2016 at 4:20 PM, Davood Rafiei
wrote:
> Hi,
>
>
> I am trying to use groupby operator in simple example. However, I get
> strange
Hi,
I am trying to use groupby operator in simple example. However, I get
strange results.
I have inputs on "test" topic like: (Long, String)
1Message_1
1Message_1
2Message_2
3Message_3
4Message_4
I want to get counts of each value. So:
Message_1 2
Message_1 1
M
