You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by gw...@apache.org on 2016/04/06 02:09:16 UTC
[09/21] kafka git commit: MINOR: Add check for empty topics iterator
in ReplicaVerificationTool.
MINOR: Add check for empty topics iterator in ReplicaVerificationTool.
Author: Ashish Singh <as...@cloudera.com>
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 <as...@cloudera.com>
Authored: Fri Apr 1 14:12:49 2016 -0700
Committer: Gwen Shapira <cs...@gmail.com>
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(