Like receiving `io` streams and quantization criterion, `Kafka` and other remote queues in a similar way like Spark streaming works.