anchor.diff:  # Configure the Kafka source (we read from it)
   mp.messaging.incoming.prices.connector=smallrye-kafka
   mp.messaging.incoming.prices.value.deserializer=org.apache.kafka.common.serialization.IntegerDeserializer
  -mp.messaging.incoming.prices.health-readiness-enabled=false
   ----
   
   More details about this configuration is available on the https://kafka.apache.org/documentation/#producerconfigs[Producer configuration] and https://kafka.apache.org/documentation/#consumerconfigs[Consumer configuration] section from the Kafka documentation. These properties are configured with the prefix `kafka`.
   
   NOTE: What about `my-data-stream`? This is an in-memory stream, not connected to a message broker.
  -
  -[TIP]
  -.What is "mp.messaging.incoming.prices.health-readiness-enabled=false"?
  -====
  -The `health-readiness-enabled` disables the readiness health check.
  -By default, it verifies that there is an active connection with the broker.
  -In our case, the connection only happens when we get the first consumer.
  -This is because the stream is consumed as an SSE, waiting lazily for the first connection to trigger the whole stream.
  -So, if you are running in an environment only routing traffic to containers that are _ready_ (such as Kubernetes), it would not send traffic to your application, which, as a consequence, will never connect to Kafka and pass the readiness check.
  -
  -More details about health reporting is given in <<kafka-health-check>>.
  -====
   
   The previous configuration does not set the Kafka _bootstrap.servers_.
   Quarkus starts a Kafka broker automatically and configures the application.
  
positive.code: 
      @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;
      }
  
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.
  