hermanjakobsen commented on code in PR #19937:
URL: https://github.com/apache/kafka/pull/19937#discussion_r2504945931
##########
streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamTask.java:
##########
@@ -1133,16 +1134,31 @@ public void updateNextOffsets(final TopicPartition
partition, final OffsetAndMet
* @throws IllegalStateException if the current node is not null
*/
public Cancellable schedule(final long interval, final PunctuationType
type, final Punctuator punctuator) {
- switch (type) {
- case STREAM_TIME:
- // align punctuation to 0L, punctuate as soon as we have data
- return schedule(0L, interval, type, punctuator);
- case WALL_CLOCK_TIME:
- // align punctuation to now, punctuate after interval has
elapsed
- return schedule(time.milliseconds() + interval, interval,
type, punctuator);
- default:
- throw new IllegalArgumentException("Unrecognized
PunctuationType: " + type);
+ return schedule(null, interval, type, punctuator);
Review Comment:
See https://github.com/apache/kafka/pull/19937#discussion_r2504941061
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
