[Solved] Given this producer code snippet using KafkaAvroSerializer: props.put("schema.registry.url", "http://localhost:8081");... What happens if userRecord does not match the registered schema? | Kafka

Kafka - Schema Registry

Given this producer code snippet using KafkaAvroSerializer:

props.put("schema.registry.url", "http://localhost:8081");
ProducerRecord record = new ProducerRecord<>("topic", userRecord);
producer.send(record);

What happens if userRecord does not match the registered schema?

AA serialization exception is thrown and message is not sent

BThe producer retries sending the message indefinitely

CThe message is sent successfully without validation

DThe message is sent but schema registry logs a warning

Step-by-Step Solution

Solution:

Step 1: Understand KafkaAvroSerializer behavior
It validates data against the schema before sending.
Step 2: Check what happens on mismatch
If data doesn't match, serialization fails and an exception is thrown, preventing send.
Final Answer:
A serialization exception is thrown and message is not sent -> Option A
Quick Check:
Schema mismatch = serialization error [OK]

Quick Trick: Mismatch triggers serialization exception, no send [OK]

Common Mistakes:

MISTAKES

Master "Schema Registry" in Kafka

9 interactive learning modes - each teaches the same concept differently

More Kafka Quizzes

Given this producer code snippet using KafkaAvroSerializer: