[Solved] Identify the error in this Kafka consumer code snippet that tries to... Identify the error in this Kafka consumer code snippet that tries to send failed messages to a DLQ: try { process(record); | Kafka

Kafka - Event-Driven Architecture

Identify the error in this Kafka consumer code snippet that tries to send failed messages to a DLQ:

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

AThe catch block should rethrow the exception

BThe producer.send method is missing a ProducerRecord object

CThe process method should not be inside try-catch

DThe record.key() cannot be used as a message key

Step-by-Step Solution

Solution:

Step 1: Check the producer.send method usage
The producer.send method requires a ProducerRecord object, not separate parameters.
Step 2: Identify correct usage
The correct call is producer.send(new ProducerRecord<>("dlq-topic", record.key(), record.value()));
Final Answer:
The producer.send method is missing 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

Identify the error in this Kafka consumer code snippet that tries to send failed messages to a DLQ: