使用 Pulsar Storm Adaptor Pulsar Spout Pulsar Bolt 示例 Pulsar Storm is an adaptor for integrating with Apache Storm topologies. It provides core Storm implementations for sendin...

使用 Pulsar Storm Adaptor Pulsar Spout Pulsar Bolt 示例 Pulsar Storm is an adaptor for integrating with Apache Storm topologies. It provides core Storm implementations for sendin...

Pulsar adaptor for Apache Storm 使用 Pulsar Storm Adaptor Pulsar Spout Pulsar Bolt Pulsar adaptor for Apache Storm Pulsar Storm is an adaptor for integrating with Apache Storm...

Storm集成Kafka 一、整合说明 二、写入数据到Kafka 2.1 项目结构 2.2 项目主要依赖 2.3 DataSourceSpout 2.4 WritingToKafkaApp 2.5 测试准备工作 1. 启动Kakfa 2. 创建topic 3. 启动消费者 2.6 测试 三、从Kafka中读取数据 3.1 项目结构 3...

内容 基础概念 配置 消息的可靠性保障 容错性 命令行操作 理解 Storm 拓扑的并发数(parallelism)概念 FAQ

内容 序列化 常用模式 使用非 JVM 语言开发 分布式 RPC Storm 与 Kestrel Hooks Metrics

内容 定义 Storm 的非 JVM 语言 DSL 多语言接口协议（如何定义其他语言的接口） 技术实现相关文档

Storm 与 Kestrel 前言 Storm Kestrel Kestrel 服务器与队列 从 Kestrel 中移除数据 向 Kestrel 中连续添加数据 使用 KestrelSpout 运行 Storm 与 Kestrel 本文说明了如何使用 Storm 从 Kestrel 集群中消费数据。 前言 Storm 本教...

Storm 集成 Redis 详解 一、简介 二、集成案例 2.1 项目结构 2.2 项目依赖 2.3 DataSourceSpout 2.4 SplitBolt 2.5 CountBolt 2.6 WordCountStoreMapper 2.7 WordCountToRedisApp 2.8 启动测试 三、storm-redis 实现...

Storm 核心概念详解 一、Storm核心概念 1.1 Topologies（拓扑） 1.2 Streams（流） 1.3 Spouts 1.4 Bolts 1.5 Stream groupings（分组策略） 二、Storm架构详解 2.1 Nimbus进程 2.2 Supervisor进程 2.3 zookeeper的作用 2.4...