MINOR: Add check for empty topics iterator in ReplicaVerificationTool. Author: Ashish Singh <[email protected]>
Reviewers: Guozhang Wang, Gwen Shapira Closes #1167 from SinghAsDev/minorFixRelicaLagTool Project: http://git-wip-us.apache.org/repos/asf/kafka/repo Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/b5de4122 Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/b5de4122 Diff: http://git-wip-us.apache.org/repos/asf/kafka/diff/b5de4122 Branch: refs/heads/0.10.0 Commit: b5de41227f11a495d5dd7e1cf785220365d84534 Parents: ae0a5a0 Author: Ashish Singh <[email protected]> Authored: Fri Apr 1 14:12:49 2016 -0700 Committer: Gwen Shapira <[email protected]> Committed: Tue Apr 5 17:08:53 2016 -0700 ---------------------------------------------------------------------- core/src/main/scala/kafka/tools/ReplicaVerificationTool.scala | 6 ++++++ 1 file changed, 6 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/kafka/blob/b5de4122/core/src/main/scala/kafka/tools/ReplicaVerificationTool.scala ---------------------------------------------------------------------- diff --git a/core/src/main/scala/kafka/tools/ReplicaVerificationTool.scala b/core/src/main/scala/kafka/tools/ReplicaVerificationTool.scala index fe4968d..71bf0c0 100644 --- a/core/src/main/scala/kafka/tools/ReplicaVerificationTool.scala +++ b/core/src/main/scala/kafka/tools/ReplicaVerificationTool.scala @@ -128,6 +128,12 @@ object ReplicaVerificationTool extends Logging { else false ) + + if (filteredTopicMetadata.isEmpty) { + error("No topics found. " + topicWhiteListOpt + ", if specified, is either filtering out all topics or there is no topic.") + System.exit(1) + } + val topicPartitionReplicaList: Seq[TopicPartitionReplica] = filteredTopicMetadata.flatMap( topicMetadataResponse => topicMetadataResponse.partitionsMetadata.flatMap(
