What is the recommended way to implement a custom SerDes for a Person class with fields name (String) and age (int)?

hard📝 Application Q8 of 15

Kafka - Advanced Stream Processing

What is the recommended way to implement a custom SerDes for a Person class with fields name (String) and age (int)?

AUse Kafka's built-in String serializer for both fields without custom code.

Create separate <code>PersonSerializer</code> and <code>PersonDeserializer</code> classes that convert <code>Person</code> objects to/from byte arrays, then combine them in a <code>PersonSerDe</code> class.

Serialize the <code>Person</code> object by calling <code>toString()</code> and deserialize by parsing the string manually.

DStore the <code>Person</code> object as JSON in a file and read it during deserialization.

Step-by-Step Solution

Solution:

Step 1: Understand custom SerDes design
Custom SerDes typically involve separate serializer and deserializer classes.
Step 2: Implement serialization logic
Serializer converts Person fields to bytes; deserializer reconstructs Person from bytes.
Step 3: Combine serializer and deserializer
Wrap both in a SerDe class for Kafka Streams compatibility.
Final Answer:
Create separate PersonSerializer and PersonDeserializer classes and combine them in a PersonSerDe class. -> Option B
Quick Check:
Separate serializer/deserializer combined in SerDe [OK]

Quick Trick: Use separate serializer and deserializer classes combined [OK]

Common Mistakes:

Using toString() for serialization without format guarantees
Relying on built-in serializers for complex objects
Storing data externally instead of in Kafka messages

Master "Advanced Stream Processing" in Kafka

9 interactive learning modes - each teaches the same concept differently

Learn Why Deep Visual Try Challenge Project Recall Time

Want More Practice?

15+ quiz questions · All difficulty levels · Free

Free Signup - Practice All Questions

More Kafka Quizzes

What is the recommended way to implement a custom SerDes for a Person class with fields name (String) and age (int)?

Step 1: Understand custom SerDes design

Step 2: Implement serialization logic

Step 3: Combine serializer and deserializer

Final Answer:

Quick Check:

Want More Practice?