Hi, deleting /hadoop/zookeeper/version-2/* didn't help in my case. Can someone suggest any alternative solution to fix this issue. ... 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