anchor.diff:  
   import io.quarkus.runtime.annotations.RegisterForReflection;
   
  +@RegisterForReflection
   public class Aggregation {
   
       public int stationId;
  
positive.code:     @Outgoing("weather-stations")                               // <3>
      public Flowable<KafkaRecord<Integer, String>> weatherStations() {
          List<KafkaRecord<Integer, String>> stationsAsJson = stations.stream()
              .map(s -> KafkaMessage.of(
                      s.id,
                      "{ \"id\" : " + s.id +
                      ", \"name\" : \"" + s.name + "\" }"))
  
negative.code: @ApplicationScoped
  public class ValuesGenerator {
  
      private static final Logger LOG = LoggerFactory.getLogger(ValuesGenerator.class);
  
      private Random random = new Random();
  
  