I wonder if it's possible somehow to delay execution of a job? Like, do something on an arrival of Kafka message, but after a minute.

best thing you could do is buffer it into a window and then have a trigger on a timer that does something

I see...

Hey all, what’s the maximum value :onyx/pending-timeout can take? I’m getting “Pending timeout cannot be greater than acking daemon timeout” error, but can’t find what’s the value of acking daemon timeout is

oh, nevermind, found it: 480000ms

@jetmind Yep, with 0.9 that value can be as large as you want it, so long as the acking daemon value stays above it.

Those two values are interdependent for message replay, which is why Onyx throws that message back.

I wonder what drawbacks are in setting acking daemon value higher than default.

@jetmind It’s the amount of time that a message’s lineage is flushed from memory, presumably because the message was lost in transit and needs to be replayed. The higher the value, the less frequently clean up will take place.

Higher value = more memory consumption, less thread activity. Lower = the inverse.

got it, thanks

Anytime!

Anyone planning on being at Clojure/west later in the month?

I wish