anchor.diff:  }
   EOF
   ----
  -
  ++
   Kafka Connect's log file should contain messages regarding execution of the initial snapshot:
  -
  ++
   [source%nowrap,bash]
   ----
   oc logs $(oc get pods -o name -l strimzi.io/name=debezium-connect)
   ----
   
  -Now you can read change events for the `customers` table from the corresponding Kafka topic:
  -
  +. Read change events for the `customers` table from the corresponding Kafka topic:
  ++
   [source%nowrap,bash]
   ----
   oc exec -it broker-kafka-0 -- /opt/kafka/bin/kafka-console-consumer.sh \
  
positive.code: # Configure credentials for the database
  oc set env dc/mysql MYSQL_ROOT_PASSWORD=debezium  MYSQL_USER=mysqluser MYSQL_PASSWORD=mysqlpw
  ----
  
  A new pod with MySQL server should be up and running:
  
  [source%nowrap,bash]
  ----
  oc get pods
  
negative.code: 
  toc::[]
  
  This procedure is for setting up {prodname} connectors on Red Hat's link:https://www.openshift.com/[OpenShift] container platform. These instructions have been tested with the two most recent releases of OpenShift. 
  
  To get started more quickly, try the link:https://learn.openshift.com/middleware/debezium-getting-started/[{prodname} online learning scenario].
  It starts an OpenShift cluster just for you, which lets you start using {prodname} in your browser within a few minutes.
  
  == {prodname} Deployment
  
  To set up Kafka and Kafka Connect on OpenShift, use the set of images that are provided by the link:https://strimzi.io/[Strimzi] project. These images offer "Kafka as a Service" by providing enterprise grade configuration files and images that bring Kafka to OpenShift.
  
  .Prerequisites
  
  * The OpenShift command line interface (`oc`) is installed.
  
  .Procedure
  
  . In your OpenShift project, enter the following commands to install the operators and templates for the Kafka broker and Kafka Connect:
  +
  [source,shell,subs="attributes",options="nowrap"]
  ----
  export STRIMZI_VERSION={strimzi-version}
  git clone -b $STRIMZI_VERSION https://github.com/strimzi/strimzi-kafka-operator
  cd strimzi-kafka-operator
  
  # Switch to an admin user to create security objects as part of installation:
  oc login -u system:admin
  oc create -f install/cluster-operator && oc create -f examples/templates/cluster-operator
  ----
  
  . Deploy a Kafka broker cluster and a Kafka Connect cluster and then create a Kafka Connect image with the {prodname} connectors installed:
  +
  [source,shell,subs="attributes",options="nowrap"]
  ----
  # Deploy an ephemeral single instance Kafka broker:
  oc process strimzi-ephemeral -p CLUSTER_NAME=broker -p ZOOKEEPER_NODE_COUNT=1 -p KAFKA_NODE_COUNT=1 -p KAFKA_OFFSETS_TOPIC_REPLICATION_FACTOR=1 -p KAFKA_TRANSACTION_STATE_LOG_REPLICATION_FACTOR=1 | oc apply -f -
  
  # Deploy a single instance of Kafka Connect with no plug-in installed:
  oc process strimzi-connect-s2i -p CLUSTER_NAME=debezium -p KAFKA_CONNECT_BOOTSTRAP_SERVERS=broker-kafka-bootstrap:9092 -p KAFKA_CONNECT_CONFIG_STORAGE_REPLICATION_FACTOR=1 -p KAFKA_CONNECT_OFFSET_STORAGE_REPLICATION_FACTOR=1 -p KAFKA_CONNECT_STATUS_STORAGE_REPLICATION_FACTOR=1 -p KAFKA_CONNECT_VALUE_CONVERTER_SCHEMAS_ENABLE=false -p KAFKA_CONNECT_KEY_CONVERTER_SCHEMAS_ENABLE=false | oc apply -f -
  
  # Build a Debezium image
  export DEBEZIUM_VERSION={debezium-version}
  mkdir -p plugins && cd plugins && \
  for PLUGIN in {mongodb,mysql,postgres,sqlserver}; do \
      curl http://central.maven.org/maven2/io/debezium/debezium-connector-$PLUGIN/$DEBEZIUM_VERSION/debezium-connector-$PLUGIN-$DEBEZIUM_VERSION-plugin.tar.gz | tar xz; \
  done && \
  oc start-build debezium-connect --from-dir=. --follow && \
  cd .. && rm -rf plugins
  ----
  +
  After a while all parts should be up and running:
  +
  [source%nowrap,bash]
  ----
  oc get pods
  