anchor.diff:        LOG_DIR: /tmp/logs
   
     kafka:
  -    image: strimzi/kafka:0.19.0-kafka-2.5.0
  +    image: quay.io/strimzi/kafka:0.23.0-kafka-2.8.0
       command: [
         "sh", "-c",
         "bin/kafka-server-start.sh config/server.properties --override listeners=$${KAFKA_LISTENERS} --override advertised.listeners=$${KAFKA_ADVERTISED_LISTENERS} --override zookeeper.connect=$${KAFKA_ZOOKEEPER_CONNECT}"
  
positive.code: ----
  package org.acme.kafka;
  
  import io.smallrye.reactive.messaging.annotations.Broadcast;
  import org.eclipse.microprofile.reactive.messaging.Acknowledgment;
  import org.eclipse.microprofile.reactive.messaging.Incoming;
  import org.eclipse.microprofile.reactive.messaging.Outgoing;
  
  
negative.code: ----
  <1> Indicates that the method consumes the items from the `prices` topic
  <2> Indicates that the objects returned by the method are sent to the `my-data-stream` stream
  
  The `process` method is called for every Kafka _record_ from the `prices` topic (configured in the application configuration).
  Every result is sent to the `my-data-stream` in-memory stream.
  