anchor.diff:  
   [source,sql]
   ----
  -2018-06-20 13:03:00 | platinum | 3
  -2018-06-20 13:04:00 | platinum | 26
  -2018-06-20 13:05:00 | platinum | 26
  -2018-06-20 13:06:00 | platinum | 20
  -2018-06-20 13:07:00 | platinum | 23
  +platinum : Window{start=1535986500000 end=-} | platinum | 23
  +silver : Window{start=1535983740000 end=-} | silver | 9
  +gold : Window{start=1535983740000 end=-} | gold | 39
  +gold : Window{start=1535983800000 end=-} | gold | 46
  +platinum : Window{start=1535983980000 end=-} | platinum | 18
   Limit Reached
   Query terminated
   ksql>
  
positive.code:     "connection.url": "http://elasticsearch:9200",
      "transforms": "ExtractTimestamp",
      "transforms.ExtractTimestamp.type": "org.apache.kafka.connect.transforms.InsertField$Value",
      "transforms.ExtractTimestamp.timestamp.field" : "EXTRACT_TS"
    }
  }'
  ----
  
  Use the Kibana interface to check that docs are arriving in Elasticsearch:
  
  image::images/kibana_01.png[]
  
  
negative.code: 
  [source,sql]
  ----
  SELECT ROWKEY, \
          CLUB_STATUS, RATING_COUNT \
  FROM RATINGS_BY_CLUB_STATUS \
  WHERE CLUB_STATUS='bronze';
  