anchor.diff:  
       @Incoming("prices")                                     // <1>
       @Outgoing("my-data-stream")                             // <2>
  -    @Broadcast                                              // <3>
  -    @Acknowledgment(Acknowledgment.Strategy.PRE_PROCESSING) // <4>
       public double process(int priceInUsd) {
           return priceInUsd * CONVERSION_RATE;
       }
  
positive.code:       LOG_DIR: /tmp/logs
  
    kafka:
      image: strimzi/kafka:0.19.0-kafka-2.5.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}"
  
negative.code: services:
  
    zookeeper:
      image: quay.io/strimzi/kafka:0.23.0-kafka-2.8.0
      command: [
        "sh", "-c",
        "bin/zookeeper-server-start.sh config/zookeeper.properties"
  