注入Apache Storm Flux的外部屬性

Question

我使用Flux 1.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文件，但它並沒有把它注射。

Answer 1

將過濾器 - 資源佔位符${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