diff --git a/core/src/main/scala/kafka/admin/AclCommand.scala b/core/src/main/scala/kafka/admin/AclCommand.scala index b697facfc6b5f..966c4beee0eba 100644 --- a/core/src/main/scala/kafka/admin/AclCommand.scala +++ b/core/src/main/scala/kafka/admin/AclCommand.scala @@ -242,7 +242,7 @@ object AclCommand { } private def confirmAction(opts: AclCommandOptions, msg: String): Boolean = { - if (opts.options.has(opts.yesOpt)) + if (opts.options.has(opts.forceOpt)) return true println(msg) Console.readLine().equalsIgnoreCase("y") @@ -331,7 +331,7 @@ object AclCommand { val helpOpt = parser.accepts("help", "Print usage information.") - val yesOpt = parser.accepts("yes", "Assume Yes to all queries and do not prompt.") + val forceOpt = parser.accepts("force", "Assume Yes to all queries and do not prompt.") val options = parser.parse(args: _*) diff --git a/core/src/test/scala/unit/kafka/admin/AclCommandTest.scala b/core/src/test/scala/unit/kafka/admin/AclCommandTest.scala index f2d963c2c9e4b..7ada48ebb8e3f 100644 --- a/core/src/test/scala/unit/kafka/admin/AclCommandTest.scala +++ b/core/src/test/scala/unit/kafka/admin/AclCommandTest.scala @@ -116,7 +116,7 @@ class AclCommandTest extends ZooKeeperTestHarness with Logging { private def testRemove(resources: Set[Resource], resourceCmd: Array[String], args: Array[String], brokerProps: Properties) { for (resource <- resources) { - AclCommand.main(args ++ resourceCmd :+ "--remove" :+ "--yes") + AclCommand.main(args ++ resourceCmd :+ "--remove" :+ "--force") withAuthorizer(brokerProps) { authorizer => TestUtils.waitAndVerifyAcls(Set.empty[Acl], authorizer, resource) } diff --git a/docs/security.html b/docs/security.html index e913ffa720220..7a1b333b724e5 100644 --- a/docs/security.html +++ b/docs/security.html @@ -577,7 +577,7 @@

Command Line Interface Convenience - --yes + --force Convenience option to assume yes to all queries and do not prompt. Convenience