Thread.sleep(100); // wait until we are "in sync"
> }
>
> // Process Topic A message
>
> ctx.putState("topicA_ts_key", msg_ts);
>
> }
> }
>
> Regards,
> David
>
> On Tue, Jul 2, 2019 at 6:28 PM Adam Bellemare
> wrote:
>
Hi All
The use-case is pretty simple. Lets say we have a history of events with
the following:
key=userId, value = (timestamp, productId)
and we want to remap it to:
key=productId, value=(original_timestamp, userId)
Now, say I have 30 days of backlog, and 2 input topics with the original
events.
