[Solved] Identify the error in this Kafka consumer code snippet:KafkaConsumer consumer = new KafkaConsumer(props); consumer.subscribe(Collections.singletonList("topic"));... | Kafka

Kafka - Advanced Stream Processing

Identify the error in this Kafka consumer code snippet:

KafkaConsumer consumer = new KafkaConsumer<>(props);
consumer.subscribe(Collections.singletonList("topic"));
while(true) {
  ConsumerRecords records = consumer.poll(Duration.ofMillis(100));
  for (ConsumerRecord record : records) {
    System.out.println(record.value());
  }
  consumer.commitAsync();
}

Apoll() duration is too short causing errors

BcommitAsync() should be commitSync() always

CMissing consumer.close() to release resources

Dsubscribe() requires a list of topics, not singletonList

Step-by-Step Solution

Solution:

Step 1: Review consumer lifecycle
Kafka consumers should be closed to release resources properly.
Step 2: Check code for missing close()
The code loops infinitely without closing consumer, causing resource leaks.
Final Answer:
Missing consumer.close() to release resources -> Option C
Quick Check:
Always close consumer to avoid leaks [OK]

Quick Trick: Always close Kafka consumer after use [OK]

Common Mistakes:

MISTAKES

Thinking commitAsync() is wrong here
Assuming poll duration causes error
Misunderstanding subscribe() argument

Master "Advanced Stream Processing" in Kafka

9 interactive learning modes - each teaches the same concept differently

Learn Why Deep Visual Try Challenge Project Recall Time

More Kafka Quizzes

Identify the error in this Kafka consumer code snippet:

Step 1: Review consumer lifecycle

Step 2: Check code for missing close()

Final Answer:

Quick Check:

Want More Practice?