Kafka Streams, Windowing, Kafka.
import java.util.Properties; public class ClickCountSlidingWindow { public static void main(String[] args) { Properties props = new Properties(); props.put(StreamsConfig.APPLICATION_ID_CONFIG, "click-count-application"); props.put(StreamsConfig.BOOTSTRAP_SERVERS_CONFIG, "localhost:9092");