流（Stream）是Redis從5.0.0版本新加入的一個數據結構，是一個類似於Kafka的訊息系統。該結構相關的大部分命令使用字母X 開頭 如XADD ,XLEN ,XRAN

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

前言 Flink 是一種流式計算框架，為什麼我會接觸到 Flink 呢？因為我目前在負責的是監控平臺的告警部分，負責採集到的監控資料會直接往 kafka 裡塞，然後告警這邊需要從 kafka topic 裡面實時讀

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

Ant Design 3.10.4 已釋出，Ant Design 是螞蟻金服開發和正在使用的一套企業級前端設計語言和基於 React 的前端框架實現。 更新內容： Mod

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

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

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

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