[Solved] Identify the issue in this Java Kafka consumer snippet:KafkaConsumer consumer = new KafkaConsumer(props); consumer.subscribe(Collections.singletonList("topic1")); ConsumerRecords records = consumer.... | Kafka

Kafka - Consumers

Identify the issue in this Java Kafka consumer snippet:

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

ASystem.out.println cannot print record values

BIncorrect subscription method used

Cpoll() method is missing a timeout parameter

DNo call to consumer.close() to release resources

Step-by-Step Solution

Solution:

Step 1: Review Code
The code subscribes correctly and polls messages.
Step 2: Identify Missing Best Practice
Consumer should be closed after use to free resources.
Final Answer:
No call to consumer.close() to release resources -> Option D
Quick Check:
poll() uses Duration correctly; subscription is valid [OK]

Quick Trick: Always close KafkaConsumer to avoid resource leaks [OK]

Common Mistakes:

Forgetting to close the consumer
Misunderstanding poll() parameters
Incorrect subscription syntax

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

Identify the issue in this Java Kafka consumer snippet:

Step 1: Review Code

Step 2: Identify Missing Best Practice

Final Answer:

Quick Check:

Want More Practice?