Stream Processing with Spring Cloud Stream and Apache Kafka Streams. Part 3 - Data deserialization and serialization
Part 1 - Programming Model Part 2 - Programming Model Continued
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 - KStream<K,V>
, KTable<K,V>
and 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…