Data Stream Processing with Kafka Streams

Ovaj rad demonstrira obradu toka podataka koristeći Processor API u programskom jeziku Java. On je jedan od dvaju API-ja koje platforma Apache Kafka nudi u sklopu programske knjižnice Kafka Streams. S obzirom na to da je Kafka Streams sastavni dio platforme, rad se prije svega fokusira na njenu arhitekturu, funkcionalnosti i terminlogiju radi lakšeg razumijevanja. Naravno, prije objašnjavnja programskog koda, glavni koncepti samog Processor API-ja su također opisani. Podaci koji se koriste za demonstraciju obrade podataka preuzeti su iz skupa podataka Aposemat IoT-23 koji sadrži mrežni promet internet uređaja.This paper demonstrates data-stream processing using the Processor API in the Java programming language. It is one of the two APIs offered by the Apache Kafka platform within the Kafka Streams library. Considering that Kafka Streams is an integral part of the platform, the paper first focuses on it's architecture, functionalities, and terminology for easier understanding. Of course, before explaining the program code, the main concepts of the Processor API are also described. The data used to demonstrate data processing is taken from the Aposemat IoT-23 dataset, which contains network traffic from internet devices