I have a KStream that I want to enrich with some values from a lookup table. When a new key enters the KStream, there's likely to be a corresponding entry arriving on the KStream at the same time, so we end up with a race condition. If the KTable record arrives first, then its value is available for joining when the corresponding arrives on the KStream. If the KStream record arrives first, however, we'll get a null join even if the KTable gets the corresponding record only milliseconds later.
I'd like to give the KTable a "head start" of ~10 seconds, so that it gets a chance to get updated before the corresponding records arrive on the KStream. Could I achieve this using one of the existing Windowing strategies?
