Processor ideas

[birdayz]

• Debounce processor - skip intermediate messages with same key. maybe consider a decider func, which decides which one to keep. i.e. debounce 10s -> only one msg per 10s is processed, rest is dropped.
• Rate Limit processor. could be tied together with debounce. somewhat difficult to implement, because blocking (long) is bad, a streams thread is supposed to not really block, because it serves other parts of the topology as well.
• Processor/Transformer wrappers that add some decorations. Example: one that sets MDC fields for the duration of the call.
• Error handling mechanism / retry mechanism for i/o stuff, that uses state store to be at-least-once