[Solved] Find the bug in this Kafka consumer code:consumer.subscribe(List.of("topic")); ConsumerRecords records = consumer.poll(100); for (ConsumerRecord record : records) { System.out.println(record.... | Kafka

Kafka - Event-Driven Architecture

Find the bug in this Kafka consumer code:

consumer.subscribe(List.of("topic"));
ConsumerRecords records = consumer.poll(100);
for (ConsumerRecord record : records) {
  System.out.println(record.value());
}

ANo bug, code is correct

Bsubscribe() needs a Set, not a List

CConsumerRecord cannot be used in for-each loop

Dpoll() requires a Duration, not an int

Step-by-Step Solution

Solution:

Step 1: Check poll() method parameter type
In modern Kafka clients, poll() expects a Duration object, not an int.
Step 2: Confirm correct usage
Use poll(Duration.ofMillis(100)) instead of poll(100).
Final Answer:
poll() requires a Duration, not an int -> Option D
Quick Check:
poll() needs Duration parameter [OK]

Quick Trick: Use Duration.ofMillis() for poll timeout [OK]

Common Mistakes:

Passing int instead of Duration to poll()
Confusing List and Set for subscribe()
Misusing ConsumerRecord in loops

Master "Event-Driven Architecture" in Kafka

9 interactive learning modes - each teaches the same concept differently

Learn Why Deep Visual Try Challenge Project Recall Time

More Kafka Quizzes

Find the bug in this Kafka consumer code:

Step 1: Check poll() method parameter type

Step 2: Confirm correct usage

Final Answer:

Quick Check:

Want More Practice?