anchor.diff:                      addresses.update(latestAddress);
                       return addresses;
                   },
  -                Materialized.as(childrenTopic+"_table_aggregate")
  -                        .withKeySerde((Serde)defaultIdSerde)
  -                            .withValueSerde(addressesSerde)
  +                Materialized.<DefaultId,Addresses,KeyValueStore<Bytes, byte[]>>
  +                        as(childrenTopic+"_table_aggregate")
  +                            .withKeySerde(defaultIdSerde)
  +                                .withValueSerde(addressesSerde)
           );
   ----
   
  
positive.code: 
  == Building DDD Aggregates
  
  The KStreams application is going to process data from two the two Kafka topics. These topics
  receive CDC events based on the customers and addresses relations found in MySQL, each of which has its
  corresponding Jackson-annotated POJO (https://github.com/hpgrahsl/kafka-streams-ddd-aggregator/blob/blog-post-sample/src/main/java/com/github/hpgrahsl/kafka/model/Customer.java[Customer] and
   https://github.com/hpgrahsl/kafka-streams-ddd-aggregator/blob/blog-post-sample/src/main/java/com/github/hpgrahsl/kafka/model/Address.java)[Address],
  enriched by a field holding the CDC event type (i.e. UPSERT/DELETE) for easier handling during the KStreams processing.
  
  Since the Kafka topic records are in Debezium JSON format with unwrapped envelopes, a special **SerDe**
  has been written in order to be able to read/write these records using their POJO or Debezium event representation respectively.
  
negative.code: 
  Concrete examples are:
  
  * **customers and their addresses** which are represented as a customer record _aggregate_
  storing a customer and a list of addresses
  
  * **orders and corresponding line items** which are represented as an order record
  _aggregate_ storing an order and all its line items
  
  Chances are that the data of the involved domain objects backing these DDD aggregates are stored in
  separate relations of an RDBMS. When making use of the CDC capabilities currently found
  