[Solved] What is wrong with the following code snippet for committing offsets manually? consumer.poll(Duration.ofMillis(1000)); consumer.commitAsync(); consumer.close(); | Kafka

Kafka - Consumers

What is wrong with the following code snippet for committing offsets manually?

consumer.poll(Duration.ofMillis(1000));
consumer.commitAsync();
consumer.close();

Aconsumer.close() should be called before commitAsync()

BcommitAsync() should be called before poll()

CcommitAsync() is called without processing polled records

Dpoll() duration is too short for commitAsync()

Step-by-Step Solution

Solution:

Step 1: Check offset commit timing
Offsets should be committed after processing records, not just after poll().
Step 2: Identify missing processing step
The code commits offsets without handling any messages, so it commits offsets that may not be processed.
Final Answer:
commitAsync() is called without processing polled records -> Option C
Quick Check:
Commit after processing, not just after poll [OK]

Quick Trick: Always process records before committing offsets [OK]

Common Mistakes:

Master "Consumers" in Kafka

9 interactive learning modes - each teaches the same concept differently

More Kafka Quizzes

What is wrong with the following code snippet for committing offsets manually?