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: ----
  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: 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"
  