[Solved] Examine this Kafka consumer code snippet:try { process(record); } catch (Exception e) { producer.send("dlq-topic", record.... } What is the issue with this code regarding sending messages to the DLQ? | Kafka

Kafka - Event-Driven Architecture

Examine this Kafka consumer code snippet:

try {
  process(record);
} catch (Exception e) {
  producer.send("dlq-topic", record.key(), record.value());
}

What is the issue with this code regarding sending messages to the DLQ?

AThe catch block does not handle the exception properly and will crash the consumer

BThe producer.send method is called with incorrect parameters; it requires a ProducerRecord object

CThe DLQ topic name is invalid and will cause a runtime error

DThe code does not commit offsets after sending to DLQ

Step-by-Step Solution

Solution:

Step 1: Review producer.send usage
The producer.send method expects a ProducerRecord object, not separate parameters.
Step 2: Identify the error
Passing topic, key, and value as separate arguments is invalid and will cause a compilation or runtime error.
Final Answer:
The producer.send method is called with incorrect parameters; it requires a ProducerRecord object -> Option B
Quick Check:
producer.send needs ProducerRecord object [OK]

Quick Trick: producer.send requires ProducerRecord, not separate args [OK]

Common Mistakes:

MISTAKES

Master "Event-Driven Architecture" in Kafka

9 interactive learning modes - each teaches the same concept differently

More Kafka Quizzes

Examine this Kafka consumer code snippet: