[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", "StringDeserializer");
props.put("value.deserializer", "StringDeserializer");
KafkaConsumer<String, String> consumer = new KafkaConsumer<>(props);

ADeserializer class names must be fully qualified with package names.

Bgroup.id cannot be set to 'group1'.

Cbootstrap.servers should be a list, not a string.

DKafkaConsumer constructor requires a second argument.

Step-by-Step Solution

Solution:

Step 1: Check deserializer class names
The deserializer class names must include the full package path, e.g., "org.apache.kafka.common.serialization.StringDeserializer".
Step 2: Validate other properties
group.id can be any string, bootstrap.servers accepts a comma-separated string, and KafkaConsumer constructor accepts a single Properties argument.
Final Answer:
Deserializer class names must be fully qualified with package names. -> Option A
Quick Check:
Deserializer names need full package = C [OK]

Quick Trick: Always use full package names for deserializers [OK]

Common Mistakes:

MISTAKES

Using short class names for deserializers
Misunderstanding group.id format
Expecting multiple constructor arguments

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 deserializer class names

Step 2: Validate other properties

Final Answer:

Quick Check:

Want More Practice?