Apache Storm Flux의 외부 속성을 입력하십시오.

Question

Flux 1.0.0을 사용 중이며 토폴로지를 YAML 파일로 다시 작성했습니다. 하지만 스톰 드라이버를 사용하여 실행하는 구성의 일부였던 일부 속성이 있습니다.

storm.Driver --config myConfig/config.conf

지금 스톰 플럭스와 함께, 어떻게 내 토폴로지에 config.conf에있는 속성을 주입 할 수 있습니까? 나는 현재

java -cp myStormJar org.apache.sotrm.flux.Flux --local /src/main/resources/myTopology.yaml를하고있는 중이 야

은 내가 conf의 파일의 경로 뒤에 --resources 옵션을 사용하려고하지만, 그것을 주입하지 않습니다.

Answer 1

필터 --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

을