actually, I see what's being done (use of [payload:x]) but it's still not really threadsafe unless guaranteed to always be used for the same column names... is that a true assumption here per-stream?