Kafka Stream Calc and Message Queue

生产者 -> Stream Processor -> 消费者