为apache storm flux注入外部属性

disho6za 于 2021-06-21 发布在 Storm

关注(0)|答案(1)|浏览(302)

我使用的是flux1.0.0，我已经将我的拓扑重写为一个yaml文件。但是我有一些属性曾经是我使用storm驱动程序运行的配置的一部分。 storm.Driver --config myConfig/config.conf 现在有了风暴通量，我如何注入 config.conf 我的拓扑结构？
我现在正在做 java -cp myStormJar org.apache.sotrm.flux.Flux --local /src/main/resources/myTopology.yaml 我试着用 --resources 选项，后跟conf文件的路径，但它不会将其注入。

apache-storm apache-storm-flux

来源：https://stackoverflow.com/questions/39702747/inject-external-properties-for-apache-storm-flux

1条答案

按热度按时间

wxclj1h51#

添加过滤器--资源占位符 ${resource.filter} 你的yaml档案。使物业在 stormConf -在中重新声明筛选器资源 config: 属性。

name: "storm-topology"

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

您还可以在以下位置查看简单的\u hdfs.yaml示例：https://github.com/ptgoetz/flux/tree/master/flux-examples

赞(0）回复(0）举报 2021-06-21

我来回答

为apache storm flux注入外部属性

1条答案

相关问题

热门标签

最新问答