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

  • 关于我们
  • 免责声明