Window Timestamps in KSQL / Integration with Elasticsearch

KSQL provides the ability to create windowed aggregations. For example, count the number of messages in a 1 minute window, grouped by a particular …