Looks like in storm/bin directory the storm-kafka-monitor command is missing in Storm 2.4.0 binary distribution
I tried to copy storm-kafka-monitor from our Storm 1.2.x installation, but the shell fails with ClassNotFound: [root@ip-172-31-44-210 bin]# ./storm-kafka-monitor Error: Could not find or load main class org.apache.storm.kafka.monitor.KafkaOffsetLagUtil Caused by: java.lang.ClassNotFoundException: org.apache.storm.kafka.monitor.KafkaOffsetLagUtil So I guess more is needed to restore Kafka lag display in Storm UI 2.4.0. Anyone having this Kafka lag display working with 2.4.0 ? Kind regards, Alexandre Le ven. 20 mai 2022 à 17:08, Alexandre Vermeerbergen <[email protected]> a écrit : > > Hello, > > We have been using Storm in production since quite a long time, with > latest Storm 1.2.x. > > After a very long hesitation, we decided to give a try to Storm 2.x, > first without rebuilding our big jars. > > The very good surprise for us is that everything seems to work. > > However, I found one major regression: with Storm 1.2.X UI we heavily > rely on "Kafka Spout lag" table to check if we have some issues with > our Spout on some partition. > > However, with Storm 2.4.x, the "Kafka Spout lag" table is no longer visible. > > Are we missing something? > > Was "Kafka Spout Lag" dropped out of Storm 2.x (I don't see such > information in Storm 2.x release notes...) > > I hope that we missing something trivial and that bringing back the > Kafka lag in Storm UI isn't much complicated. > > Any ideas ? > > Kind regards, > Alexandre
