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)
- }
- }
-
}