Hi, deleting /hadoop/zookeeper/version-2/* didn't help in my case. Can someone suggest any alternative solution to fix this issue. ... View more

Sandeep, I have tried with multiple browsers as well. Issue is still replicating. May i know where can i find the storm logs in the unix server (ambari). They may help me understand what's the issue is. ... View more

Hi Sandeep, thanks for your kind response. I have tried doing the both options that you have suggested me. But still, i'm facing the same issue. I have killed the existing storm topology (from CLI) and submitted a new topology after that. Even the new topology does seem to be loading. Issue still persists. Can you Please help me with another way-out for this issue. Regards, Sandeep Kumar ... View more

Hi @Timothy Spann, i'm facing the similar issue on my HDP cluster. My cluster details (HDP 2.6.0.3, Kafka 0.10.1, Storm 1.1.0) When i'm trying to run the storm code, it's executing successfully. But on storm UI, under "Topology spouts lag error" it gives out the below error, "Unable to get offset lags for kafka. Reason: org.apache.kafka.shaded.common.errors.InvalidTopicException: Topic '[samplenftest]' is invalid" Also, the URLs mentioned here in the post to fix the issue, are not accessible (gives 404 error) https://github.com/hortonworks/storm/blob/HDF-3.0.0.0/external/storm-kafka-client/src/main/java/org/apache/storm/kafka/spout/NamedSubscription.java#L59 https://github.com/hortonworks/storm/blob/HDF-3.0-maint/external/storm-kafka-client/src/main/java/org/apache/storm/kafka/spout/NamedSubscription.java#L62 Can you please help me out on how to resolve this issue. Regards, Sandeep. ... View more

Hi @pshah, i'm facing the similar issue on my HDP cluster. My cluster details (HDP 2.6.0.3, Kafka 0.10.1, Storm 1.1.0) When i'm trying to run the storm code, it's executing successfully. But on storm UI, under "Topology spouts lag error" it gives out the below error, "Unable to get offset lags for kafka. Reason: org.apache.kafka.shaded.common.errors.InvalidTopicException: Topic '[samplenftest]' is invalid" Also, the URLs mentioned here in the post to fix the issue, are not accessible (gives 404 error) https://github.com/hortonworks/storm/blob/HDF-3.0.0.0/external/storm-kafka-client/src/main/java/org/apache/storm/kafka/spout/NamedSubscription.java#L59 https://github.com/hortonworks/storm/blob/HDF-3.0-maint/external/storm-kafka-client/src/main/java/org/apache/storm/kafka/spout/NamedSubscription.java#L62 Can you please help me out on how to resolve this issue. Regards, Sandeep. ... View more