从"开始"设置风暴拓扑的日志级别



我在初始化期间在我的 Storm 拓扑中出现了一个错误。 我想从拓扑启动时将日志级别设置为 DEBUG。

我意识到有一种机制可以使用 Storm UI 或 CLI 为正在运行的拓扑动态设置日志级别,但我无法在初始化期间拓扑中出现错误之前动态更改此设置。

如何将日志级别静态设置为 DEBUG,以便在初始化拓扑时可以看到更详细的日志?

以下内容仅适用于 Storm 2.0.0 及更高版本。

您可以在拓扑 jar 中包含 log4j2 配置文件。然后,需要在拓扑配置中设置topology.logging.config属性。

为方便起见,我将在此处包含文档:

用户可用于配置 Log4j2 的日志文件。可以是 jar 中的资源(使用 classpath:/path/to/resource 指定(或文件。除了常规工作线程 log4j2 配置之外,还应用此配置。配置根据以下规则合并:https://logging.apache.org/log4j/2.x/manual/configuration.html#CompositeConfiguration

见 https://github.com/apache/storm/blob/885ca981fc52bda6552be854c7e4af9c7a451cd2/storm-client/src/jvm/org/apache/storm/Config.java#L735

"常规工作线程 log4j2 配置"是 Storm 部署中的 log4j2/worker.xml 文件,假设默认设置。

最新更新