Bird
Raised Fist0

Which of the following is the correct way to configure a Kafka producer for schema validation using Avro serializer in Java?

easy📝 Syntax Q3 of Q15
Kafka - Schema Registry
Which of the following is the correct way to configure a Kafka producer for schema validation using Avro serializer in Java?
Aprops.put("value.serializer", "org.apache.kafka.common.serialization.StringSerializer");
Bprops.put("value.serializer", "io.confluent.kafka.serializers.KafkaAvroSerializer");
Cprops.put("key.serializer", "io.confluent.kafka.serializers.KafkaAvroSerializer");
Dprops.put("value.serializer", "org.apache.kafka.common.serialization.ByteArraySerializer");
Step-by-Step Solution
Solution:
  1. Step 1: Identify correct serializer for Avro values

    The Avro serializer class is "io.confluent.kafka.serializers.KafkaAvroSerializer" for values.
  2. Step 2: Check options for correct usage

    props.put("value.serializer", "io.confluent.kafka.serializers.KafkaAvroSerializer"); correctly sets value.serializer to the Avro serializer; others use wrong serializers or key.serializer.
  3. Final Answer:

    props.put("value.serializer", "io.confluent.kafka.serializers.KafkaAvroSerializer"); -> Option B
  4. Quick Check:

    Avro serializer config = value.serializer with KafkaAvroSerializer [OK]
Quick Trick: Use KafkaAvroSerializer for value.serializer to enable schema validation [OK]
Common Mistakes:
MISTAKES
  • Setting key.serializer instead of value.serializer
  • Using StringSerializer instead of Avro serializer
  • Confusing ByteArraySerializer with Avro serializer

Want More Practice?

15+ quiz questions · All difficulty levels · Free

Free Signup - Practice All Questions
More Kafka Quizzes