anchor.diff:      @Outgoing("weather-stations")                               // <3>
       public Flowable<KafkaRecord<Integer, String>> weatherStations() {
           List<KafkaRecord<Integer, String>> stationsAsJson = stations.stream()
  -            .map(s -> KafkaMessage.of(
  +            .map(s -> KafkaRecord.of(
                       s.id,
                       "{ \"id\" : " + s.id +
                       ", \"name\" : \"" + s.name + "\" }"))
  
positive.code: @ApplicationScoped
  public class ValuesGenerator {
  
      private static final Logger LOG = Logger.getLogger(ValuesGenerator.class);
  
      private Random random = new Random();
  
  
negative.code: import javax.enterprise.context.ApplicationScoped;
  
  import org.eclipse.microprofile.reactive.messaging.Outgoing;
  import org.slf4j.Logger;
  import org.slf4j.LoggerFactory;
  
  import io.reactivex.Flowable;
  import io.smallrye.reactive.messaging.kafka.KafkaRecord;
  