anchor.diff:  
   import io.quarkus.runtime.annotations.RegisterForReflection;
   
  -@RegisterForReflection
  +@RegisterForReflection // <1>
   public class WeatherStation {
   
       public int id;
       public String name;
   }
   ----
  +<1> By adding the `@RegisterForReflection` annotation, it is ensured that this type can be instantiated reflectively when running the application in native mode.
   
   Then the file `aggregator/src/main/java/org/acme/quarkus/sample/kafkastreams/model/TemperatureMeasurement.java`,
   representing temperature measurements for a given station:
  
positive.code:         }
      }
      else {                                                              // <3>
          LOG.info("Found data for key {} on remote host {}:{}", id, metadata.host(), metadata.port());
          return GetWeatherStationDataResult.foundRemotely(metadata.host(), metadata.port());
      }
  }
  
negative.code:                         (stationId, timestampAndValue) -> stationId,
                          (timestampAndValue, station) -> {
                              String[] parts = timestampAndValue.split(";");
                              return new TemperatureMeasurement(station.id, station.name,
                                      Instant.parse(parts[0]), Double.valueOf(parts[1]));
                          }
                  )
                  .groupByKey()                                                 // <5>
  