Window Timestamps in KSQL / Integration with Elasticsearch