apache-storm - 为 Apache Storm Flux 注入外部属性

Question

我正在使用 Flux 1.0.0，并且已将拓扑重写为 YAML 文件。但是我有一些属性曾经是我使用 Storm 驱动程序运行的配置的一部分。

storm.Driver --config myConfig/config.conf

现在有了 Storm Flux，我怎样才能将属性注入config.conf到我的拓扑中？

我目前正在做java -cp myStormJar org.apache.sotrm.flux.Flux --local /src/main/resources/myTopology.yaml

我尝试使用--resources选项，后跟 conf 文件的路径，但它没有注入它。

score 1 · Accepted Answer

将过滤器 --resources 占位符添加${resource.filter}到您的 yaml 文件中。使属性可用stormConf- 在属性中重新声明过滤器资源config:。

name: "storm-topology"

config:
    kafka.mapper.zkPort: ${kafka.mapper.zkPort}
    kafka.mapper.zkServers: ${kafka.mapper.zkServers}

您还可以在以下位置查看 simple_hdfs.yaml 示例：https ://github.com/ptgoetz/flux/tree/master/flux-examples

1 回答 1