You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by ch...@apache.org on 2020/10/21 03:00:23 UTC

[kafka] branch trunk updated: MINOR: Remove unused TopicCommand.askToProceed() method (#9465)

This is an automated email from the ASF dual-hosted git repository.

chia7712 pushed a commit to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git


The following commit(s) were added to refs/heads/trunk by this push:
     new df3d287  MINOR: Remove unused TopicCommand.askToProceed() method (#9465)
df3d287 is described below

commit df3d287b426fc21af4ddaa4f97334e454619a869
Author: Kowshik Prakasam <kp...@confluent.io>
AuthorDate: Tue Oct 20 19:59:18 2020 -0700

    MINOR: Remove unused TopicCommand.askToProceed() method (#9465)
    
    Reviewers: Gwen (Chen) Shapira <cs...@gmail.com>, Chia-Ping Tsai <ch...@gmail.com>
---
 core/src/main/scala/kafka/admin/TopicCommand.scala | 10 ----------
 1 file changed, 10 deletions(-)

diff --git a/core/src/main/scala/kafka/admin/TopicCommand.scala b/core/src/main/scala/kafka/admin/TopicCommand.scala
index b9171bb..95129e9 100755
--- a/core/src/main/scala/kafka/admin/TopicCommand.scala
+++ b/core/src/main/scala/kafka/admin/TopicCommand.scala
@@ -45,7 +45,6 @@ import scala.jdk.CollectionConverters._
 import scala.collection._
 import scala.compat.java8.OptionConverters._
 import scala.concurrent.ExecutionException
-import scala.io.StdIn
 
 object TopicCommand extends Logging {
 
@@ -776,14 +775,5 @@ object TopicCommand extends Logging {
       CommandLineUtils.checkInvalidArgs(parser, options, excludeInternalTopicOpt, allTopicLevelOpts -- Set(listOpt, describeOpt))
     }
   }
-
-  def askToProceed(): Unit = {
-    println("Are you sure you want to continue? [y/n]")
-    if (!StdIn.readLine().equalsIgnoreCase("y")) {
-      println("Ending your session")
-      Exit.exit(0)
-    }
-  }
-
 }