anchor.diff:  ----
   
   === Persist stream-table join
  -
   
   [source,sql]
   ----
  
positive.code:                     --topic ratings
  ----
  
  [source,bash]
  ----
  {"rating_id":{"long":13323},"user_id":{"int":19},"stars":{"int":3},"route_id":{"int":5676},"rating_time":{"long":1528279580480},"channel":{"string":"iOS"},"message":{"string":"your team here rocks!"}}
  ----
  
  Is Elasticsearch running?
  
  [source,bash]
  ----
  curl http://localhost:9200
  ----
  
  [source,bash]
  ----
  {
    "name" : "0-JgLQj",
  
negative.code: kibana                              /usr/local/bin/kibana-docker     Up      0.0.0.0:5601->5601/tcp
  ----
  
  === Are the connectors running?
  
  [source,bash]
  ----
  $ curl -s "http://localhost:8083/connectors" | jq '.[]'| xargs -I{connector_name} curl -s "http://localhost:8083/connectors/"{connector_name}"/status" | jq -c -M '[.name,.connector.state,.tasks[].state]|join(":|:")'| column -s : -t| sed 's/\"//g'| sort
  
  pg-source  |  RUNNING  |  RUNNING
  
  $ curl -s "http://localhost:18083/connectors" | jq '.[]'| xargs -I{connector_name} curl -s "http://localhost:18083/connectors/"{connector_name}"/status" | jq -c -M '[.name,.connector.state,.tasks[].state]|join(":|:")'| column -s : -t| sed 's/\"//g'| sort
  
  es_sink_ratings-with-customer-data  |  RUNNING  |  RUNNING
  es_sink_unhappy_platinum_customers  |  RUNNING  |  RUNNING
  jdbc_sink_postgres                  |  RUNNING  |  RUNNING
  ----
  
  === Is ratings data being produced?
  
  [source,bash]
  ----
  