I had encountered similar problem and I was using stream to table join.
However if a record arrives late in the table, it would not join as per
stream to table join semantics.
Unfortunately windowing is not supported in stream to table join.
I suggest to use stream to stream join with appropriate
Hello,
According to the docs, Kafka Streams tasks pick from the partition with the
smallest timestamp to process the next record.
(
https://kafka.apache.org/documentation/streams/core-concepts#streams_out_of_ordering
)
One can also configure max.task.idle.ms so that Kafka Streams tasks wait
for al