PROSAGA码农传奇-storm-Apache Storm：storm-kafka-monitor脚本抛出异常

<div class =“post-text”itemprop =“text”>
  <P>
    正如您所知，脚本是一个bash文件。该功能（显示日志末端在Storm UI中偏移了喷口的距离）目前在Windows上不起作用。这有点不方便，但它不应该阻止您的拓扑正常工作。
  </p>
  <P>
    如果您想知道spout的日志结束偏移量有多远，您可以在其中一台Kafka计算机上使用kafka-consumer-groups.bat脚本。如果你正在使用
     <code>
      storm-kafka-client
    </code>
     spout，spout lag也是该组件提供的指标的一部分。
  </p>
  <P>
    我希望我们能摆脱它
     <code>
      storm-kafka-monitor
    </code>
     在某些时候（它有一些其他问题
    <a href="https://issues.apache.org/jira/browse/STORM-2600" rel="nofollow noreferrer">
      https://issues.apache.org/jira/browse/STORM-2600
    </A>
    ），但在此之前，如果你想尝试提供Windows兼容性，你需要移植
    <a href="https://github.com/apache/storm/blob/master/bin/storm-kafka-monitor" rel="nofollow noreferrer">
      https://github.com/apache/storm/blob/master/bin/storm-kafka-monitor
    </A>
     到cmd / powershell，并修改
    <a href="https://github.com/apache/storm/blob/4137328b75c06771f84414c3c2113e2d1c757c08/storm-core/src/jvm/org/apache/storm/utils/TopologySpoutLag.java#L146" rel="nofollow noreferrer">
      https://github.com/apache/storm/blob/4137328b75c06771f84414c3c2113e2d1c757c08/storm-core/src/jvm/org/apache/storm/utils/TopologySpoutLag.java#L146
    </A>
     所以它根据操作系统调用Windows或bash脚本。
  </p>
</DIV>