Re: KTable.suppress(Suppressed.untilWindowCloses) does not suppress some non-final results when the kafka streams process is restarted

2018-12-21 Thread Peter Levart
Hello Guozhang, Thank you for looking into this problem. I noticed that I have been using an internal class constructor and later discovered the right API to create the StrictBufferConfig implementations. But I'm afraid that using your proposed factory method won't change anything since its i

Re: KTable.suppress(Suppressed.untilWindowCloses) does not suppress some non-final results when the kafka streams process is restarted

2018-12-21 Thread Peter Levart
Hello Guozhang, May I just add some more observations which might help you pin-point the problem... When the process that runs the kafka streams processing threads is restarted, I can see duplicates in the output topic. But that is understandable for "at least once semantics" and I don't min

Local city Kafka user Meet-up

2018-12-21 Thread Ascot Moss
Hi, >From Kafka site, I can see there a number of events about local MEET-UPs, many of them are far away from my city, http://kafka.apache.org/events Can anyone advise how to add the link of my local Kafka meet up to the event page in Kafka site as I wish to have more people to join local meet-u