發(fā)簡信
IP屬地：湖北
-
使用Lenses（1）——Lensens儀表板及管理主題Lenses支持Restful API和websockets刽锤，但也有一個用戶界面舶赔。 本節(jié)介紹主要功能的基本用法焕妙。 Lenses儀表板 Lense...
-
功能概述Lenses是 Apache Kafka的流式數(shù)據(jù)管理平臺瓦呼。它提供了Kafka的核心元素以及 web 用戶界面和企業(yè)功能旅挤。這將在使用 Apach...
-
映射
一切威、概述 （1）映射映射是定義文檔如何被存儲和索引的伍宦，包括含有哪些字段，字段的類型啃憎，字符串類型的字段應(yīng)當(dāng)作為全文本還是關(guān)鍵字，日期字段的格式等等...
-
Alpakka
Alpakka為集成各種用例似炎，提供了各種Akka Stream連接器辛萍、集成模式和數(shù)據(jù)轉(zhuǎn)換。 例如Spring Web Spring 5.0引入了...
-
Akka之Source相關(guān)API總結(jié)
（1）apply[T](iterable: immutable.Iterable[T]): Source[T, NotUsed]由Iterabl...
-
Akka之Flow相關(guān)API總結(jié)
（1）viaMat[T, Mat2, Mat3](flow: Graph[FlowShape[Out, T], Mat2])(combine: ...
-
Akka Stream之使用流式IO
Akka Sream提供了一種使用流處理文件IO和TCP連接的方法羡藐。雖然一般方法與使用Akka IO 的基于Actor的 TCP 處理非常相似,...
-
Akka Stream之流中的錯誤處理
當(dāng)流中的某個階段失敗時, 通常會導(dǎo)致整個流被拆掉贩毕。此時，每個階段的下游得到關(guān)于失敗通知和上游得到關(guān)于取消通知仆嗦。 在許多情況下, 您可能希望避免完...
-
Akka HTTP之服務(wù)器發(fā)送的事件支持
服務(wù)器發(fā)送的事件（SSE）是一個用于將通知從 HTTP 服務(wù)器推送到客戶端輕量級辉阶、標(biāo)準(zhǔn)化協(xié)議。與提供雙向通信的 WebSocket 相比, SS...