http://edisonxu.com/2018/11/30/akka-kafka-producer.html
Akka Stream在用Akka去对接Kafka之前,有必要先简单了解下Akka Stream,它是基于Reactive Stream(Akka是其创立成员之一)的。Akka Stream中,将流的拓扑处理逻辑命名为Graph,拓扑中每个操作命名为Operator。它将流式处理抽象为几个核心API: Source : 有且仅有一个Output的operator,对应数据的来源,将数据反序列化后
http://edisonxu.com/2018/11/30/akka-kafka-producer.html
Akka Stream在用Akka去对接Kafka之前,有必要先简单了解下Akka Stream,它是基于Reactive Stream(Akka是其创立成员之一)的。Akka Stream中,将流的拓扑处理逻辑命名为Graph,拓扑中每个操作命名为Operator。它将流式处理抽象为几个核心API: Source : 有且仅有一个Output的operator,对应数据的来源,将数据反序列化后