Hi All,

I'm building a streams applications where I wish to take action on the
input when a certain frequency of the input has been seen.

At the moment the application roughly goes:

frequency table = Input Stream -> groupByKey -> Count

input stream with counts = leftJoin frequency table and input stream

branch input stream with counts where count > some threshold send to some
other topic, if <= some threshold send to delay processing topic.

delay stream with counts = leftJoin frequency table and delay stream

branch delay stream with counts where count > some threshold send to some
other topic, if <= some threshold send to delay processing topic.

I've seen intermittent failures where the frequency table is giving a null
on join, no matter how long I wait content coming back in on the delayed
stream keeps getting nulls for the count when looking up the frequency
table.

Any ideas why this might be occurring?

Thanks,

Ian.

Reply via email to