anchor.diff:  ----
   
   When all components are started we are going to register the Elasticsearch Sink connector writing into the Elasticsearch instance.
  -We want to use the same key (primary id) in the source and both PostgreSQL and Elasticsearch.
  +We want to use the same key (primary id) in the source and both PostgreSQL and Elasticsearch:
  +
   [source,bash,indent=0]
   ----
   curl -i -X POST -H "Accept:application/json" -H  "Content-Type:application/json" http://localhost:8083/connectors/ -d @es-sink.json
   ----
   
  -Using this registration request:
  +We're using this registration request:
   
   [source,json,indent=0]
   ----
  
positive.code: We again use the `UnwrapFromEnvelope` transformation to automatically extract a new row record and thus effectively convert the Debezium change data message into a simple one consumable by other connectors. Both JDBC and Elasticsearch connectors expect the same format.
  
  == Example
  Let's move directly to our example as that's where the changes are visible.
  
  First of all we need to deploy all components.
  [source,bash,indent=0]
  ----
  export DEBEZIUM_VERSION=0.6
  
negative.code: 
  &nbsp; +
  
  We are going to simplify the deployment again, so we will use only one Kafka Connect instance that will contain all connectors and will serve as both as entry point and exit point for Kafka.
  
  &nbsp; +
  
  