anchor.diff:  * Setting up AMQ Streams storage
   * Installing {registry}
   
  -. Extract the {prodname} connector archive(s) to create a directory structure for the connector plug-in(s). If you downloaded and extracted the archive for each {prodname} connector, the structure looks like this:
  +. Extract the {prodname} connector archives to create a directory structure for the connector plug-ins. 
  +If you downloaded and extracted the archives for multiple {prodname} connectors, the resulting directory structure looks like the one in the following example:
   +
   [subs=+macros]
   ----
  
positive.code: oc logs $(oc get pods -o name -l strimzi.io/name=my-connect-cluster-connect)
  ----
  
  .. Review the log output to verify that the initial snapshot has been executed. You should see something like the following lines: 
  +
  [source,shell,options="nowrap"]
  ----
  
negative.code: 
  .. Push your custom image to your container registry, for example:
  +
  `docker push _<myregistry.io>_/debezium-container-with-avro:latest`
  
  .. Point to the new container image. Do one of the following:
  +
  * Edit the `KafkaConnect.spec.image` property of the `KafkaConnect` custom resource. 
  If set, this property overrides the `STRIMZI_DEFAULT_KAFKA_CONNECT_IMAGE` variable in the Cluster Operator. 
  For example:
  +
  [source,yaml,subs=attributes+]
  ----
  