Punctuators for time-based triggers in Kafka - Practice Problems & Coding Challenges

Challenge - 5 Problems

❓ Predict Output

intermediate

Output of a Punctuator with Fixed Interval

Consider a Kafka Streams application with a punctuator scheduled every 1000 milliseconds. What will be the output printed if the punctuator prints the current timestamp every time it triggers, and the stream runs for 3 seconds?

Kafka

streamsBuilder.stream("input-topic")
  .process(() -> new Processor<String, String>() {
    private ProcessorContext context;
    @Override
    public void init(ProcessorContext context) {
      this.context = context;
      this.context.schedule(Duration.ofMillis(1000), PunctuationType.WALL_CLOCK_TIME, timestamp -> {
        System.out.println("Punctuator triggered at: " + timestamp);
      });
    }
    @Override
    public void process(String key, String value) {}
    @Override
    public void close() {}
  });

A Infinite lines printed continuously without delay

B Three lines printed with timestamps approximately 1000ms apart

C No output printed because punctuator is never triggered

D One line printed with the timestamp at start

💡 Hint

Think about how often the punctuator is scheduled and how long the stream runs.

The punctuator is scheduled to run every 1000 milliseconds (1 second). Since the stream runs for 3 seconds, the punctuator triggers approximately 3 times, printing the timestamp each time.

❓ Predict Output

intermediate

Behavior of STREAM_TIME Punctuator

What is the output behavior of a punctuator scheduled with PunctuationType.STREAM_TIME that triggers every 500 milliseconds in Kafka Streams?

Kafka

context.schedule(Duration.ofMillis(500), PunctuationType.STREAM_TIME, timestamp -> {
  System.out.println("Stream time punctuator at: " + timestamp);
});

A Triggers once at the start and never again

B Triggers every 500ms wall-clock time regardless of stream time

C Triggers continuously without waiting for stream time advancement

D Triggers only when stream time advances by 500ms, printing timestamps accordingly

💡 Hint

STREAM_TIME punctuators depend on the progress of stream time, not wall-clock time.

STREAM_TIME punctuators trigger only when the stream time (based on record timestamps) advances by the scheduled interval. They do not trigger based on wall-clock time.

🔧 Debug

advanced

Why does this Punctuator never trigger?

Given the following Kafka Streams punctuator code, why does the punctuator never print any output?

Kafka

context.schedule(Duration.ofMillis(1000), PunctuationType.STREAM_TIME, timestamp -> {
  System.out.println("Triggered at " + timestamp);
});

A Because no records with advancing timestamps are processed, so stream time never advances

B Because the schedule method is called outside the init method

C Because Duration.ofMillis(1000) is invalid for STREAM_TIME punctuators

D Because PunctuationType.STREAM_TIME punctuators require manual triggering

💡 Hint

STREAM_TIME punctuators depend on stream time advancing.

STREAM_TIME punctuators trigger only when stream time advances. If no records with increasing timestamps are processed, the punctuator never triggers.

🧠 Conceptual

advanced

Difference Between WALL_CLOCK_TIME and STREAM_TIME Punctuators

Which statement correctly describes the difference between WALL_CLOCK_TIME and STREAM_TIME punctuators in Kafka Streams?

A WALL_CLOCK_TIME triggers only when records arrive; STREAM_TIME triggers on system clock

B WALL_CLOCK_TIME triggers only once; STREAM_TIME triggers repeatedly at fixed intervals

C WALL_CLOCK_TIME triggers based on real time intervals; STREAM_TIME triggers based on record timestamps advancing

D WALL_CLOCK_TIME triggers based on record timestamps; STREAM_TIME triggers based on processing time

💡 Hint

Think about what each punctuator type uses as its timing source.

WALL_CLOCK_TIME punctuators trigger based on the system clock at fixed intervals regardless of data. STREAM_TIME punctuators trigger only when the stream time (record timestamps) advances.

📝 Syntax

expert

Identify the Syntax Error in Punctuator Scheduling

Which option contains a syntax error in scheduling a punctuator in Kafka Streams?

A context.schedule(1000, PunctuationType.WALL_CLOCK_TIME, timestamp -> System.out.println(timestamp));

B context.schedule(Duration.ofMillis(500), PunctuationType.STREAM_TIME, (timestamp) -> { System.out.println(timestamp); });

C context.schedule(Duration.ofSeconds(1), PunctuationType.WALL_CLOCK_TIME, timestamp -> System.out.println(timestamp));

D context.schedule(Duration.ofMinutes(1), PunctuationType.STREAM_TIME, timestamp -> System.out.println(timestamp));

💡 Hint

Check the type of the first argument to schedule method.

The schedule method requires a java.time.Duration object as the first argument. Passing an integer like 1000 directly causes a syntax or compilation error.