Get Started Free
Wade Waldron

Wade Waldron

Staff Software Practice Lead

Serializers & Deserializers


Serialization is a critical topic when working with Flink because it often serializes things you might not expect. Flink has two different types of serialization: Internal and External. And within each type, there are multiple formats that might be used. Depending on your choices it can have an impact on message size, flexibility, schema evolution, and more. This video will outline the different ways that Flink uses serializers and show you how to implement a few of the basics.


  • Serialization and Deserialization
  • Internal and External Serialization
  • POJO serialization vs Kryo serialization
  • JSON Serialization


A Simple POJO

public class Person {
	public String name;
	private String email;

	public Person() {}

	public String getEmail() {return email;}
	public void setEmail(String email) { = email;}

Registring Kryo Serializers


Disabling Kryo Serialization



JsonSerializationSchema<MyClass> serializer = 
	new JsonSerializationSchema<>();


JsonDeserializationSchema<MyClass> deserializer = 
	new JsonDeserializationSchema<>(MyClass.class);

Custom Object Mapper

JsonSerializationSchema<MyClass> serializer = 
	new JsonSerializationSchema<>(() -> 
		new ObjectMapper()
			.registerModule(new JavaTimeModule())


Use the promo code FLINKJAVA101 to get $25 of free Confluent Cloud usage

Be the first to get updates and new content

We will only share developer content and updates, including notifications when new content is added. We will never send you sales emails. 🙂 By subscribing, you understand we will process your personal information in accordance with our Privacy Statement.