anchor.diff:  import javax.enterprise.context.ApplicationScoped;
   
   import org.eclipse.microprofile.reactive.messaging.Outgoing;
  -import org.jboss.logging.Logger;
  +import org.slf4j.Logger;
  +import org.slf4j.LoggerFactory;
   
   import io.reactivex.Flowable;
   import io.smallrye.reactive.messaging.kafka.KafkaRecord;
  
positive.code: 
  import io.quarkus.runtime.annotations.RegisterForReflection;
  
  public class Aggregation {
  
      public int stationId;
  
negative.code:     @Outgoing("weather-stations")                               // <3>
      public Flowable<KafkaRecord<Integer, String>> weatherStations() {
          List<KafkaRecord<Integer, String>> stationsAsJson = stations.stream()
              .map(s -> KafkaRecord.of(
                      s.id,
                      "{ \"id\" : " + s.id +
                      ", \"name\" : \"" + s.name + "\" }"))
  