[KAFKA-13817] Schedule nextTimeToEmit to system time every time instead of just once

• Type: Improvement
• Status: Resolved
• Priority: Minor
• Resolution: Fixed
• Fix Version/s: 3.5.0
• Component/s: streams
• Labels: beginner newbie
• Assignee: Lim Qing Wei
• Reporter: Hao Li
• Created: 11/Apr/22 17:15
• Updated: 28/Dec/22 20:33
• Resolved: 28/Dec/22 20:33

Description

https://github.com/apache/kafka/blob/trunk/streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamKStreamJoin.java#L229-L231.

 

If this is just scheduled once, this can trigger emit every time if system time jumps a lot suddenly.

 

For example, 

1. nextTimeToEmit set to 1 and step is 1
2. If next system time jumps to 100, we will always emit for next 100 records

Issue Links

• links to: GitHub Pull Request #12166