240 发简信
IP属地:湖北
  • Resize,w 360,h 240
    使用Lenses(1)——Lensens仪表板及管理主题

    Lenses支持Restful API和websockets,但也有一个用户界面。 本节介绍主要功能的基本用法。 Lenses仪表板 Lense...

  • Resize,w 360,h 240
    功能概述

    Lenses是 Apache Kafka的流式数据管理平台。它提供了Kafka的核心元素以及 web 用户界面和企业功能。这将在使用 Apach...

  • 映射

    一、概述 (1)映射映射是定义文档如何被存储和索引的,包括含有哪些字段,字段的类型,字符串类型的字段应当作为全文本还是关键字,日期字段的格式等等...

  • Alpakka

    Alpakka为集成各种用例,提供了各种Akka Stream连接器、集成模式和数据转换。 例如Spring Web Spring 5.0引入了...

  • Akka之Source相关API总结

    (1)apply[T](iterable: immutable.Iterable[T]): Source[T, NotUsed]由Iterabl...

  • Akka之Flow相关API总结

    (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之流中的错误处理

    当流中的某个阶段失败时, 通常会导致整个流被拆掉。此时,每个阶段的下游得到关于失败通知和上游得到关于取消通知。 在许多情况下, 您可能希望避免完...

  • Akka HTTP之服务器发送的事件支持

    服务器发送的事件(SSE)是一个用于将通知从 HTTP 服务器推送到客户端轻量级、标准化协议。与提供双向通信的 WebSocket 相比, SS...