Kafka - Advanced Stream Processing
You want to emit aggregated results every 30 seconds using a punctuator in Kafka Streams. Which of the following code snippets correctly schedules this punctuator and ensures it triggers based on wall-clock time?
Which of the following code snippets correctly schedules this punctuator and ensures it triggers based on wall-clock time?
hard📝 Application Q15 of 15
Step-by-Step Solution
Solution:
Step 1: Determine the correct interval and time type
The requirement is every 30 seconds and based on wall-clock time.Step 2: Match the correct schedule call
context.schedule(Duration.ofSeconds(30), PunctuationType.WALL_CLOCK_TIME, timestamp -> emitResults()) uses Duration.ofSeconds(30) and PunctuationType.WALL_CLOCK_TIME, which is correct.Step 3: Check other options for errors
context.schedule(Duration.ofSeconds(30), PunctuationType.STREAM_TIME, timestamp -> emitResults()) uses STREAM_TIME, not wall-clock; C uses int instead of Duration; D uses 1 minute instead of 30 seconds.Final Answer:
context.schedule(Duration.ofSeconds(30), PunctuationType.WALL_CLOCK_TIME, timestamp -> emitResults()) -> Option CQuick Check:
Wall-clock 30s interval = context.schedule(Duration.ofSeconds(30), PunctuationType.WALL_CLOCK_TIME, timestamp -> emitResults()) [OK]
Quick Trick: Use Duration.ofSeconds(30) with WALL_CLOCK_TIME for 30-second triggers [OK]
Common Mistakes:
MISTAKES- Using STREAM_TIME instead of WALL_CLOCK_TIME
- Passing raw integers instead of Duration
- Setting wrong time interval
Master "Advanced Stream Processing" in Kafka
Want More Practice?
15+ quiz questions · All difficulty levels · Free
Free Signup - Practice All QuestionsMore Kafka Quizzes