如何在 Samza worker 上获取应用程序 ID?

How get Application Id on Samza worker?

我不需要 "container id" 或 "App Attempt Id"。

documentation 上,我看到我们可以为 log4j 配置放置 ${samza.log.dir},此路径包含应用程序 ID。就像 /foo/log/../application_id_123

我找到了解决方法,如果你知道更好的解决方法可以回复。

 final String samzaLogDir = System.getProperty("samza.log.dir");
 final String[] samzaLogDirSplit = samzaLogDir.split("/");
 final String applicationId = samzaLogDirSplit[samzaLogDirSplit.length - 2];