java - 如何在Samza worker上获得应用程序ID？

Question

我不需要“容器ID”或“应用尝试ID”。

在documentation上，我看到我们可以将${samza.log.dir}放在log4j配置中，并且该路径包含应用程序ID。就像/foo/log/../application_id_123

Answer 1

我找到了解决方案，如果您知道更好的解决方案，则可以答复。

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