定义 SpoutConfig 参数

【问题标题】：Define SpoutConfig parameter定义 SpoutConfig 参数
【发布时间】：2015-10-02 22:17:27
【问题描述】：

我有一个 Storm 拓扑，我在其中使用 KafkaSpout。

BrokerHosts zk = new ZkHosts("localhost:2181");
SpoutConfig spoutConf = new SpoutConfig(zk, "topic", "/topic", "discovery");

我想知道SpoutConfig中传递的第三个和第四个参数。

是第三个参数，安装Zookeeper的Zookeeper根路径还是dataDir路径？
第4个参数是一个ID，但是不知道为什么要用，应该给什么？

【问题讨论】：

标签： java apache-kafka apache-storm apache-zookeeper

【解决方案1】：

zkRoot 和 id 用于构造storm存储kafka偏移量的zookeeper路径。你可以阅读它here。

spout 存储它在 Zookeeper 中消耗的偏移量的状态。 spout 使用根路径进行参数化，以存储此特定 spout 的偏移量和 id。因此，分区的偏移量将存储在这些路径中，其中“0”、“1”是分区的 ID：

{根路径}/{id}/0
{根路径}/{id}/1
{根路径}/{id}/2
{根路径}/{id}/3
...

【讨论】：