logo
  • 教程列表
  • SO官方文檔
  • apache-flink 教程
    • 從卡夫卡那裡獲取資料
      • 內建反序列化模式
      • Kafka 分割槽和 Flink 並行
      • KafkaConsumer 的例子
      • 容錯
    • 儲存點和外部化檢查點
      • 外部檢查點(Flink 1.2)
      • 儲存點要求和初步說明
      • 儲存點
    • 日誌
      • 記錄配置
      • 在程式碼中使用記錄器
      • 為每個應用程式使用不同的配置
      • Flink-on-Yarn 解決方法使用 rsyslog 實時獲取日誌
    • 檢查點
      • 配置和設定
      • 測試檢查點
    • apache-flink 入門
      • 概述和要求
      • 本地執行時設定
      • Flink 環境設定
      • WordCount - 表 API
      • 字數
      • WordCount - 流式 API
    • 如何定義自定義(反)序列化架構
      • 自定義架構示例
    • 表格 API
      • Maven 依賴
      • 來自 CSV 的簡單聚合
      • 加入表格示例
      • 使用外部 Sink
  1. StackOverflow 文件
  2. apache-flink 教程
  3. 從卡夫卡那裡獲取資料

    從卡夫卡那裡獲取資料

  • 內建反序列化模式 Kafka 分割槽和 Flink 並行 KafkaConsumer 的例子 容錯
  • 內建反序列化模式

Copyright © 2018. All right reserved

tastones.com 备案号:鲁ICP备18045372号-1

  • 關於本站
  • 免責聲明