Egg.js ： 基於KOA2的企業級框架 Kafka：高吞吐量的分散式釋出訂閱訊息系統 本文章將整合egg + kafka + mysql 的日誌系統例子 系統要求：日誌記錄，通過kafka進行訊

Apache Kylin社群於日前宣佈：Apache Kylin v2.5.1  正式釋出！歡迎大家下載使用。 Apache Kylin 是一個開源的分散式分析引擎，提供 Hadoo

這個demo是基於springboot專案的。 名詞介紹： Shiro Shiro 主要分為 安全認證 和 介面授權 兩個部分，其中的核心元件為 Subject、 SecurityManager、

安全公告編號:CNTA-2018-0029 2018年11月7日，國家資訊安全漏洞共享平臺（CNVD）收錄了Apache Struts2 Commons FileUpload反序列化遠端程式碼執行漏洞（

序 在大資料系統中Kafka應用廣泛，藉助原始碼閱讀可以加深對元件的理解，同時可以拾起Scala語言。 安裝依賴軟體 JDK Scala Gradle Zookee

1.工具說明 技術:註解+(設計模式)(單例-內部類懶載入,責任鏈,工廠模式)+自動掃包 優點: 1.非侵入式外掛(可以很容易新增到

Maxwell 是一個讀取 MySQL binlogs 並將修改行欄位的更新寫入 Kafka, Kinesis, RabbitMQ, Google Cloud Pub/Sub 或 Redis (Pub/Sub

一， Kafka 消費模式 從 kafka 消費訊息， kafka 客戶端提供兩種模式 : 分割槽消費，分組消費。 分割槽消費對應的就是我們的 DirectKafkaInputDStream

點選上方藍字關注【 北郵郭大寶 】 最近實習需要開發一套Spark Streaming的實時流處理專案，內心還是很期待的。說來慚愧，做大資料開發實習一年有餘了，都是離線批處理的任務，還沒親自操

第1步：生成我們的專案：Spring Initializr 來生成我們的專案。我們的專案將提供Spring MVC / Web支援和Apache Kafka支援。 第2步：釋出/讀取Kafka

shiro支援多個realm，當設定多個realm的時候，shiro的認證和授權的步驟是怎樣的呢。 多個realm認證原理： 發現需要在執行認證的時候，需要策略來處理多個re

Kafka 訊息的 Producer 在呼叫producer.send() 方法傳送訊息時會先把訊息放到本地緩衝中，然後由  Kafka 網路執行緒從緩衝中提取訊息再送到 Kafka 代理上去。本地緩

本文中，我們來看下用  Structured Streaming 怎麼處理 kafka中的複雜json 資料流，Structured Streaming 強項我們都知道，可以使用 event-time  進行聚

如何在流行而強大的 Apache Web 伺服器上託管兩個或多個站點。 在我的上一篇文章中，我解釋瞭如何為單個站點配置 Apache Web 伺服器，事實證明這很容易。在這篇文章中，我將向你展示如何使用單

EventSourcing事件溯源是儲存這些實體相關的事件流（實則是明細表），而不是直接儲存實體的“當前”狀態。每個事件都是一個事實，它描述了實體發生的狀態變化（過去時態！）。眾所周知，事實是無可爭議的，不可改