You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
For take operations will be nice to handle both amount of record and within timeout, to avoid to stale processing when the amount of values is not reached.
@vertexclique check the implementation of take on faust. It supports an amount of records, in combination with a parameter called within.
Imaging to have a stream.take(100).
The problem with the above code is that it will block forever if there are 99 messages and the last hundredth message is never received.
To solve this add a within timeout so that up to 100 values will be processed within 10 seconds.
group_by
items
: iterate over both key and value at the same timeevents
: access raw eventstake
: buffer up specific amount of values from a streamenumerate
: count valuesthrough
: forward through yet another topic/stream.filter
: filter values to omit from streamecho
: repeat to one or more topics.The text was updated successfully, but these errors were encountered: