Hello Guozhang,
Thanks for your reply.
I created the following issue: https://issues.apache.org/jira/browse/KAFKA-6323
I also further analyzed the memory problem and found out that it is a
non-issue. It was only a consequence of the above issue and happened
because at each punctuation I
Hello Fred,
Thanks for reporting the issue.
1) Nice find about the punctuation start time with WALL_CLOCK_TIME type. I
agree with you that this should better be initialized as current time
+ interval.
Do you mind creating a JIRA for Kafka? And if you'd like to submit a patch
for it that would be
Hello all,
I am using kafka and kafka-streams 1.0.0
When working on a custom Processor from which I am scheduling a
punctuation using WALL_CLOCK_TIME. I've noticed that whatever the
punctuation interval I set, a call to my Punctuator is always
triggered immediately. Is that a bug?
Having a
