Kafka - Event-Driven Architecture
Given the following Kafka consumer code snippet, what happens when message processing fails?
try {
processMessage(record);
} catch (Exception e) {
producer.send(new ProducerRecord<>("dlq-topic", record.key(), record.value()));
}