[Solved] Identify the error in this Kafka consumer code snippet:Properties props = new Properties(); props.put("bootstrap.servers", "localhost:9092"); props.put("group.id", "group1"); props.put("key.... | Kafka

Kafka - with Java/Python

Identify the error in this Kafka consumer code snippet:

Properties props = new Properties();
props.put("bootstrap.servers", "localhost:9092");
props.put("group.id", "group1");
props.put("key.deserializer", "org.apache.kafka.common.serialization.StringDeserializer");
props.put("value.deserializer", "org.apache.kafka.common.serialization.StringDeserializer");
KafkaConsumer<String, String> consumer = new KafkaConsumer<>(props);
consumer.subscribe(Collections.singletonList("my-topic"));
ConsumerRecords<String, String> records = consumer.poll(100);
for (ConsumerRecord<String, String> record : records) {
    System.out.println(record.value());
}

Agroup.id property is missing

Bsubscribe() should use assign()

CDeserializers are incorrectly set

Dpoll() argument should be Duration, not int

Step-by-Step Solution

Solution:

Step 1: Check poll() method signature
In modern Kafka clients, poll requires a Duration argument, not an int.
Step 2: Identify incorrect argument type
The code uses poll(100) (int), should be poll(Duration.ofMillis(100)).
Final Answer:
poll() argument should be Duration, not int -> Option D
Quick Check:
poll() needs Duration argument [OK]

Quick Trick: Use Duration.ofMillis() with poll(), not plain int [OK]

Common Mistakes:

MISTAKES

Passing int to poll() instead of Duration
Missing group.id property
Using assign() instead of subscribe()

Master "with Java/Python" 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: Check poll() method signature

Step 2: Identify incorrect argument type

Final Answer:

Quick Check:

Want More Practice?