gt;
> > is there any mathematical rules to create specific no.of partitions for
> > Topic.???
> >
> >
> > please help me
> >
> > Sent from Outlook<http://aka.ms/weboutlook>
> > ________
> > From: Jose Lopez
&
y mathematical rules to create specific no.of partitions for
> Topic.???
>
>
> please help me
>
> Sent from Outlook<http://aka.ms/weboutlook>
>
> From: Jose Lopez
> Sent: 25 April 2019 16:34
> To: users@kafka.apache.org
> Su
Hey, Jose,
This is an interesting thought that I hadn't considered before. I think
(tentatively) that windowsFor should *not* take the grace period into
account.
What I'm thinking is that the method is supposed to return "all windows
that contain the provided timestamp" . When we keep window1 op
create specific no.of partitions for
Topic.???
please help me
Sent from Outlook<http://aka.ms/weboutlook>
From: Jose Lopez
Sent: 25 April 2019 16:34
To: users@kafka.apache.org
Subject: [Streams] TimeWindows ignores gracePeriodMs in windowsFor(timestamp)
Hi all,
Given that gradePeriodMs is "the time to admit late-arriving events after
the end of the window", I'd expect it is taken into account in
windowsFor(timestamp). E.g.:
sizeMs = 5
gracePeriodMs = 2
advanceMs = 3
timestamp = 6
| window | windowStart | windowEnd | windowsEnd + gracePeriod |
|
