[Solved] Consider this Kafka consumer snippet:try { handle(record); } catch (Exception e) { producer.send(new ProducerRecord("dlq-topic", record.... } What is the effect if handle(record) throws an exception? | Kafka

Kafka - Event-Driven Architecture

Consider this Kafka consumer snippet:

try {
  handle(record);
} catch (Exception e) {
  producer.send(new ProducerRecord<>("dlq-topic", record.key(), record.value()));
}

What is the effect if handle(record) throws an exception?

AThe message is sent to the "dlq-topic" for later inspection

BThe consumer retries processing the message indefinitely

CThe message is discarded without notification

DThe consumer shuts down immediately

Step-by-Step Solution

Solution:

Step 1: Analyze try-catch block
If handle(record) throws, the catch block executes.
Step 2: Check catch block action
The catch block sends the failed message to the "dlq-topic" using the producer.
Final Answer:
The message is sent to the "dlq-topic" for later inspection -> Option A
Quick Check:
Exception triggers DLQ send [OK]

Quick Trick: Exception triggers sending message to DLQ topic [OK]

Common Mistakes:

MISTAKES

Master "Event-Driven Architecture" in Kafka

9 interactive learning modes - each teaches the same concept differently

More Kafka Quizzes

Consider this Kafka consumer snippet: