[Solved] This Kafka consumer code has a bug:consumer.subscribe(['payments']) for message in consumer: process(message) # missing commit hereWhat problem can this cause in complex flows? | Kafka

Kafka - Advanced Stream Processing

This Kafka consumer code has a bug:

consumer.subscribe(['payments'])
for message in consumer:
    process(message)
    # missing commit here

What problem can this cause in complex flows?

AMessages will be lost immediately

BMessages may be processed multiple times after restart

CConsumer will crash on first message

DMessages will be processed out of order

Step-by-Step Solution

Solution:

Step 1: Identify missing commit effect
Without committing offsets, Kafka does not know messages were processed.
Step 2: Consequence on restart
Consumer restarts and reprocesses same messages, causing duplicates.
Final Answer:
Messages may be processed multiple times after restart -> Option B
Quick Check:
Missing commit = Duplicate processing [OK]

Quick Trick: Always commit offsets to avoid duplicates [OK]

Common Mistakes:

MISTAKES

Master "Advanced Stream Processing" in Kafka

9 interactive learning modes - each teaches the same concept differently

More Kafka Quizzes

This Kafka consumer code has a bug: