話說上回中，KafkaProducer已經將生產的記錄追加到了RecordAccumulator中。那麼接下來的事情，就是怎麼樣把這些記錄提交到服務端了。 是否還記得在KafkaProducer.doSen

消費者輪詢通過拉取器（Fetcher）傳送拉取請求，拉取器會呼叫消費者網路客戶端的傳送方法(send)和網路輪詢方法（poll）。在拉取器的層面拉取請求是沒有真正傳送到服務端的。傳送方法只是把請求存在到變數中，

AI 前線導讀：“卷皮網”是一家專注高性價比商品的移動電商 ，日活躍高達 1000 多萬，隨著卷皮網的快速發展，資料規模快速增長，叢集資料儲存量成指數倍增大，伺服器規模達到 100+ 臺，與此同時公司的

data Artisans宣佈推出Streaming Ledger ，它擴充套件了Apache Flink，提供了跨表、鍵和事件流執行可序列化ACID事務的功能。這項正在申請專利的技術是Flink的專有附加

- Dashboard - 分析頁 - 監控頁 - 工作臺 - 表單頁 - 基礎表單頁 - 分步表單頁 - 高階表單頁 - 列表頁 - 查詢表格 - 標準列表

Apache Wicket 8.1.0 釋出了，Wicket 是一個 Java 語言的 Web 開發框架，與 Struts、WebWork、Tapestry 相類似，其特點在於對 Html 和程式碼進行了有效的

本文來自 網易雲社群 作者：閩濤 背景 Cloudera在2016年釋出了新型的分散式儲存系統——kudu，kudu目前也是apache下面的開源專案。Hadoop生態圈中的技術繁多，HDFS作

序 Kafka是一個基於日誌的流處理平臺，一個topic可以有多個分割槽（partition），分割槽是複製的基本單元，在單節點上，一個分割槽的資料檔案可以儲存在多個磁碟目錄中，配置項是：

前 言 本文將描述如何使用 elasticsearch、 fluentd 、 kibana構建容器化日誌收集系統 原創作者：吳鵬 介 紹 elasticsearch： 一個分散

編輯推薦: 本文來自於網路，本文首先從Kafka的架構著手，先

在本文中，我們將深入探討Flink新穎的檢查點機制是如何工作的，以及它是如何取代舊架構以實現流容錯和恢復。我們在各種型別的流處理應用程式上對Flink效能進行測試，並通過在Apache Storm（一種廣泛使用

快，關注這個公眾號，一起漲知識~ 本文介紹了druid的基礎架構以及工作過程，通過一個應用案例加深瞭解。 上篇文章回顧：玩轉 Linux cron durid簡介 d

前言 前面的幾篇部落格都是說的使用者如何認證,如何授權,那麼使用者認證授權之後,我們該如何使用這些資訊呢?這裡我們就需要使用到Shiro框架中的攔截器功能.通過攔截器功能實現使用者許可權

前言 上一篇部落格,我們說到如何在使用者請求的時候,攔截使用者請求進行操作,這一篇部落格我們來聊一下如何使用Shiro標籤在網頁之中進行使用者角色和許可權控制.那麼,我們就看一下具體的場

前言 前面的兩篇部落格使用了INI的形式完成了使用者的認證授權操作.我曾經多次在部落格中提到過INI檔案形式進行認證授權只適用於使用者較少的情況下,但是,當用戶較多的情況下,我們可能需要