[Solved] What is wrong with this consumer configuration snippet? Properties props = new Properties(); props.put("group.id", "my-group"); props.put("enable.auto.commit", "false"); props.put("auto.offset.... | Kafka

Kafka - Consumers

What is wrong with this consumer configuration snippet?

Properties props = new Properties();
props.put("group.id", "my-group");
props.put("enable.auto.commit", "false");
props.put("auto.offset.reset", "latest");
props.put("key.deserializer", "org.apache.kafka.common.serialization.StringDeserializer");
props.put("value.deserializer", "org.apache.kafka.common.serialization.StringDeserializer");
KafkaConsumer consumer = new KafkaConsumer<>(props);

Agroup.id should be an integer

BMissing bootstrap.servers configuration

Cenable.auto.commit should be true

DDeserializers should be classes, not strings

Step-by-Step Solution

Solution:

Step 1: Check required Kafka consumer configs
bootstrap.servers is mandatory to specify Kafka brokers.
Step 2: Validate other configs
group.id is a string, enable.auto.commit can be false, deserializers are specified by class name strings.
Final Answer:
Missing bootstrap.servers configuration -> Option B
Quick Check:
bootstrap.servers is required config [OK]

Quick Trick: Always set bootstrap.servers in consumer properties [OK]

Common Mistakes:

Omitting bootstrap.servers
Using wrong type for group.id
Misconfiguring deserializers

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 consumer configuration snippet?

Step 1: Check required Kafka consumer configs

Step 2: Validate other configs

Final Answer:

Quick Check:

Want More Practice?