#java #hadoop #apache-storm
#java #hadoop #apache-storm
Вопрос:
Моя топология storm имеет некоторые параметры времени выполнения. например, тема kafka для прослушивания, идентификатор группы потребителей kafka и т. Д. Если через 5 месяцев после развертывания топологии кто-то захочет проверить, какие параметры использовались, было бы хорошо, чтобы они были доступны во время выполнения. на веб-странице nimbus или где-то еще. я знаю, что могу просто регистрировать их, но журналы вращаются.
как это обычно делается? или каков способ storm достичь этого?
Комментарии:
1. Если вы уже используете Kafka в своем кластере, вам также необходимо использовать Zookeeper. Итак, я бы рекомендовал использовать Zookeeper в качестве централизованного хранилища конфигурации для свойств конфигурации пользователя. В этом случае все свойства конфигурации будут доступны с помощью CLI Zookeeper или какого-либо клиента пользовательского интерфейса.
2. поддерживается ли это каким-либо образом storm? любой открытый API или я должен все это запрограммировать самостоятельно?
3. Насколько я знаю, внутренне Storm имеет интеграцию с Zookeeper, но в вашем случае вы должны реализовать требуемую логику самостоятельно.