;
Date: 2018-04-27 16:08
To: users<mailto:users@kafka.apache.org>
Subject: Re: Re: kafka steams with TimeWindows ,incorrect result
Hi:
I don't kown what to do with transform function.
and stream is preapred well
like this at blew
key:
44_14_2018-04-27
value:
CountInfo(start=1,activ
？
funk...@live.com
From: Guozhang Wang<mailto:wangg...@gmail.com>
Date: 2018-04-27 01:50
To: users<mailto:users@kafka.apache.org>
Subject: Re: Re: kafka steams with TimeWindows ,incorrect result
Using a control message to flush results to downstream (in your case to the
result db) look
Fri, Mar 9, 2018 at 9:45 PM, 杰 杨 <funk...@live.com> wrote:
>>
>> > thx for your reply!
>> > I see that it is designed to operate on an infinite, unbounded stream of
>> > data.
>> > now I want to process for unbounded stream but divided by time
>> interval .
>> >
.@gmail.com>
> Date: 2018-03-12 03:58
> To: users<mailto:users@kafka.apache.org>
> Subject: Re: Re: kafka steams with TimeWindows ,incorrect result
> If you want to strictly "only have one output per window", then for now
> you'd probably implement that logic using
ngg...@gmail.com>
Date: 2018-03-12 03:58
To: users<mailto:users@kafka.apache.org>
Subject: Re: Re: kafka steams with TimeWindows ,incorrect result
If you want to strictly "only have one output per window", then for now
you'd probably implement that logic using a lower-level "transform
t; From: Guozhang Wang<mailto:wangg...@gmail.com>
> Date: 2018-03-10 02:50
> To: users<mailto:users@kafka.apache.org>
> Subject: Re: kafka steams with TimeWindows ,incorrect result
> Hi Jie,
>
> This is by design of Kafka Streams, please read this doc for more details
ngg...@gmail.com>
Date: 2018-03-10 02:50
To: users<mailto:users@kafka.apache.org>
Subject: Re: kafka steams with TimeWindows ,incorrect result
Hi Jie,
This is by design of Kafka Streams, please read this doc for more details
(search for "outputs of the Wordcount application is actually a
Hi Jie,
This is by design of Kafka Streams, please read this doc for more details
(search for "outputs of the Wordcount application is actually a continuous
stream of updates"):
https://kafka.apache.org/0110/documentation/streams/quickstart
Note this semantics applies for both windowed and
