Stream Processing with Spring Cloud Stream and Apache Kafka Streams. Part 3 - Data deserialization and serialization
Continuing on the previous two blog posts, in this series on writing stream processing applications with Spring Cloud Stream and Kafka Streams, now we will look at the details of how these applications handle deserialization on the inbound and serialization on the outbound.
All three major higher-level types in Kafka Streams -
GlobalKTable<K,V> - work with a key and a value.
With Spring Cloud Stream Kafka Streams support, keys are always deserialized and serialized by using the native
Serde mechanism. A
Serde is a container object where it provides a deserializer and a serializer.