• Project was implemented with Scala and Flink framework. • Utilized DataStream API connected with Kafka to analyze hot items every 5 minutes in the last hour by window functions. • Calculated website page visits and the number of unique visitors in streaming data. • Using Apache Maven for building the project and managing dependencies better.