如何在SAMZA工作人员上获取应用ID

Question

我不需要"容器ID"或"应用程序尝试ID"。

在文档上，我看到我们可以为log4j配置放置${samza.log.dir}，并且此路径包含应用程序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];