[Solved] What is wrong with this code snippet that attempts to commit offsets asynchronously?consumer.commitAsync(new OffsetCommitCallback() { public void onComplete(Map offsets, Exception e) { System.out.... | Kafka

Kafka - Consumers

What is wrong with this code snippet that attempts to commit offsets asynchronously?

consumer.commitAsync(new OffsetCommitCallback() {
  public void onComplete(Map offsets, Exception e) {
    System.out.println("Offsets committed");
  }
});

AThe callback does not handle exceptions

BcommitAsync requires a map argument, not a callback

CThe method onComplete should be named onCommitComplete

DcommitAsync cannot be used with anonymous classes

Step-by-Step Solution

Solution:

Step 1: Review commitAsync callback signature
The onComplete method receives an Exception parameter which should be checked to handle commit failures.
Step 2: Identify missing exception handling
The code prints success message without checking if Exception e is null or not, ignoring possible commit errors.
Final Answer:
The callback does not handle exceptions -> Option A
Quick Check:
Always check exceptions in commitAsync callback [OK]

Quick Trick: Check exceptions in commitAsync callback to catch errors [OK]

Common Mistakes:

Ignoring exception parameter in callback
Misnaming callback methods
Assuming commitAsync needs map argument

Master "Consumers" in Kafka

9 interactive learning modes - each teaches the same concept differently

Learn Why Deep Visual Try Challenge Project Recall Time

More Kafka Quizzes

What is wrong with this code snippet that attempts to commit offsets asynchronously?

Step 1: Review commitAsync callback signature

Step 2: Identify missing exception handling

Final Answer:

Quick Check:

Want More Practice?