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: ## Outlook
  
  In this post we described an approach for creating aggregated events from Debezium's CDC events.
  In a follow-up blog post we may dive a bit more into the topic of partitioning and ...
  _//TODO: give a glimpse on planned upcoming blog posts..._
  
  We also thought about providing a ready-to-use component which would work in a generic way
  (based on Connect records, i.e. not tied to a specific serialization format such as JSON) and
  
negative.code:         "topics": "final_ddd_aggregates",
          "mongodb.connection.uri": "mongodb://mongodb:27017/inventory?w=1&journal=true",
          "mongodb.collection": "customers_with_addresses",
          "mongodb.document.id.strategy": "at.grahsl.kafka.connect.mongodb.processor.id.strategy.FullKeyStrategy",
          "mongodb.delete.on.null.values": true
      }
  }
  ----
  