Apache Flink

Shiro實戰(五) - 會話管理

Shiro提供了完整的企業級會話管理功能,不依賴於底層容器(如web容器Tomcat),不管JavaSE還是JavaEE環境都可以使用,提供了會話管理、會話事件監聽、會話儲存/持久化、容器無關的叢集、失效/過期

Shiro 實戰(二)-授權

1 簡介 授權,也叫訪問控制,即在應用中控制誰能訪問哪些資源(如訪問頁面/編輯資料/頁面操作等) 在授權中需瞭解的幾個關鍵物件:主體(Subject)、資源(Resource)、許

如何將kafka中的資料快速匯入Hadoop?

Kafka是一個分散式釋出—訂閱系統,由於其強大的分散式和效能特性,迅速成為資料管道的關鍵部分。它可完成許多工作,例如訊息傳遞、指標收集、流處理和日誌聚合。Kafka的另一個有效用途是將資料匯入Hadoop。使

Kafka控制器選舉流程剖析

1.概述 平時在使用Kafka的時候,可能關注的更多的是Kafka系統層面的。今天來給大家剖析一下Kafka的控制器,瞭解一下Kafka控制器的選舉流程。 2.內容 Kafka控制器,其實就是一個K

使用Spring Boot和Kafka Streams實現CQRS

本文是David Romero一篇Spring + Kafka Stream實現CQRS的案例程式碼: 去年九月,我的同事伊萬·古鐵雷斯和我談到我們cowokers如何實現事件與Kafka Stream,我

BookKeeper 叢集搭建及使用

隨著 Apache Pulsar 成為 Apache 的頂級開源專案,其儲存層的解決方案 Apache BookKeeper 再次受到業界廣泛關注。BookKeeper 在 Pulsar 之前也有很多成功的應

Structured Streaming 實現超低延遲

浪院長,最近忙死了,寫文章的時間都沒了。但是,都說時間就像海綿裡的水,擠擠就有了。所以,今晚十點半開始整理這篇Structured streaming 相關的文章。 最近,忙於開發完善flink平臺,並且使

Kafka學習筆記 -- 讀取資料

消費者從屬於消費者群組。一個群組裡的消費者 訂閱的是同一個主題 , 每個消費者接收主題一部分分割槽的訊息 消費者橫向擴充套件 1個消費者 主題T1有4個分割槽,然後建立消費者C1,C

1746028576.5733