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

唯品會實時平臺現狀 目前在唯品會實時平臺並不是一個統一的計算框架，而是包括Storm，Spark，Flink在內的三個主要計算框架。由於歷史原因，當前在Storm平臺上的job數量是最多的，但是從去年開始，

環境準備 Kafka 版本：kafka_2.10-0.10.2.0（2.10表示Scala版本 0.10.2.0表示Kafka版本） 官方下載地址：

實際問題 很多大資料計算產品，都對使用者提供了SQL API，比如Hive, Spark, Flink等，那麼SQL作為傳統關係資料庫的查詢語言，是應用在批查詢場景的。Hive和Spark本質上都是Batch的

首先WAF（Web Application Firewall），俗稱Web應用防火牆，主要的目的實際上是用來過濾不正常或者惡意請求包，以及為伺服器打上臨時補丁的作用。 1、雲waf： 在配置雲waf時（

21CTO 導讀：資料流是大資料世界中極為重要的過程。在本篇中，我與各位看官一起了解它如何幫助我們進行實時分析與資料提取。 資料流之定義 何謂資料流，它就

流（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、

序 在大資料系統中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