Priority: P1
Flink has compose files but no actual stream processing job.
What to do
- Create a Flink SQL job reading from
clickstream-events Kafka topic
- Compute windowed aggregation (1-minute tumbling window: counts by action + device)
- Write results to new Kafka topic or ClickHouse via JDBC sink
- Document how to submit via Flink Dashboard at
:8083
Acceptance criteria
Priority: P1
Flink has compose files but no actual stream processing job.
What to do
clickstream-eventsKafka topic:8083Acceptance criteria