Getting Started Analyzing Twitter Data in Apache Kafka through KSQL

You'll probably get a screenful of results; this is because KSQL is actually emitting the aggregation values for the given hourly window each time it updates. Since we've set KSQL to read all messages on the topic (SET'auto.offset.reset' 'earliest';) it's reading all of these messages at once and calculating the aggregation updates as it goes. Our inbound stream of tweets is just that--a stream. But now that we are creating aggregates, we have actually created a table. A table is a snapshot of a given key's values at a given point in time.