For stateful processing you need something like: * https://kafka.apache.org/documentation/streams/ https://kafka.apache.org/documentation/streams/ - Kafka Stre

For stateful processing you need something like: * https://kafka.apache.org/documentation/streams/ https://kafka.apache.org/documentation/streams/ - Kafka Streams (and its KTable) * https://flink.apache.org/ https://flink.apache.org/ - Flink * https://spark.apache.org/streaming/ https://spark.apache.org/streaming/ - Spark Streaming * https://github.com/asavinov/bistro https://github.com/asavinov/bistro - Bistro Streams The focus of Benthod seems to be performance and resilience (implemented without persistence).