Внедрить внешние свойства для 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, но он не вставляет его.

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