發(fā)簡信
IP屬地：湖北
-
使用Lenses（1）——Lensens儀表板及管理主題Lenses支持Restful API和websockets词身，但也有一個(gè)用戶界面。 本節(jié)介紹主要功能的基本用法。 Lenses儀表板 Lense...
-
功能概述Lenses是 Apache Kafka的流式數(shù)據(jù)管理平臺(tái)许溅。它提供了Kafka的核心元素以及 web 用戶界面和企業(yè)功能。這將在使用 Apach...
-
映射
一秉版、概述 （1）映射映射是定義文檔如何被存儲(chǔ)和索引的贤重，包括含有哪些字段，字段的類型清焕，字符串類型的字段應(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之流中的錯(cuò)誤處理
當(dāng)流中的某個(gè)階段失敗時(shí), 通常會(huì)導(dǎo)致整個(gè)流被拆掉粥惧。此時(shí)键畴，每個(gè)階段的下游得到關(guān)于失敗通知和上游得到關(guān)于取消通知。 在許多情況下, 您可能希望避免完...
-
Akka HTTP之服務(wù)器發(fā)送的事件支持
服務(wù)器發(fā)送的事件（SSE）是一個(gè)用于將通知從 HTTP 服務(wù)器推送到客戶端輕量級(jí)、標(biāo)準(zhǔn)化協(xié)議起惕。與提供雙向通信的 WebSocket 相比, SS...