I am implementing stream to stream join using a 5-minute window. for that, I am using a custom time extractor as well. I am adding UTC epoch mill in my field using
KStream<String, Status> data = request.join(generate, (req, gen) -> recordBuilder.check(req, gen), JoinWindows.of(Duration.ofMillis(300000L))) foreach((k, v) -> log.info("ID = " + k + " Status = " + v));
I am adding data in both the topic with nanosecond differences. Or you can say at the same time.
But I am unable to retrieve data in the window.
Any help is appreciated.