Re: Using TumblingEventTimeWindows on low traffic kafka topic

2022-12-22 Thread deepthi s
gt; > Best regards, > Yuxia > > -- > *发件人: *"deepthi s" > *收件人: *"User" > *发送时间: *星期四, 2022年 12 月 22日 上午 9:46:00 > *主题: *Using TumblingEventTimeWindows on low traffic kafka topic > > (Adding subject) > > On Wed, Dec 21, 2022 at 5:41 PM d

Re: Using TumblingEventTimeWindows on low traffic kafka topic

2022-12-22 Thread yuxia
/kafka/#idleness [2] https://nightlies.apache.org/flink/flink-docs-release-1.15/docs/dev/datastream/event-time/generating_watermarks/#dealing-with-idle-sources Best regards, Yuxia 发件人: "deepthi s" 收件人: "User" 发送时间: 星期四, 2022年 12 月 22日 上午 9:46:00 主题: Using TumblingEve

Using TumblingEventTimeWindows on low traffic kafka topic

2022-12-21 Thread deepthi s
(Adding subject) On Wed, Dec 21, 2022 at 5:41 PM deepthi s wrote: > Hello, I am new to even-time processing and need some help. > > > > We have a kafka source with very low qps and multiple topic partitions > have no data for long periods of time. Additionally, data from the source > can come o