[Solved] Given this Kafka Streams code snippet, what is the output if a failure occurs before commit? streams.start(); try { streams.process(record); streams.commitTransaction();... | Kafka

Kafka - Advanced Stream Processing

Given this Kafka Streams code snippet, what is the output if a failure occurs before commit?

streams.start();
try {
  streams.process(record);
  streams.commitTransaction();
} catch (Exception e) {
  streams.abortTransaction();
}

AProcessed record is committed multiple times.

BProcessed record may be duplicated after restart.

CProcessed record is committed exactly once.

DProcessed record is lost and not committed.

Step-by-Step Solution

Solution:

Step 1: Analyze transaction handling
If an exception occurs before commit, abortTransaction() is called, rolling back changes.
Step 2: Determine output effect
Rollback means the processed record is not committed and effectively lost in this run.
Final Answer:
Processed record is lost and not committed. -> Option D
Quick Check:
Abort transaction = no commit = lost record [OK]

Quick Trick: Abort transaction means no commit, so data is lost [OK]

Common Mistakes:

Master "Advanced Stream Processing" in Kafka

9 interactive learning modes - each teaches the same concept differently

More Kafka Quizzes

Given this Kafka Streams code snippet, what is the output if a failure occurs before commit?