[kafka] branch 1.1 updated: MINOR: Update docs for KIP-229 (#4499)

[jg...@apache.org]

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

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


The following commit(s) were added to refs/heads/1.1 by this push:
     new efc4176  MINOR: Update docs for KIP-229 (#4499)
efc4176 is described below

commit efc4176ac7184854e37ab52ff922390869198b9d
Author: Vahid Hashemian <va...@us.ibm.com>
AuthorDate: Thu Feb 1 22:04:14 2018 -0800

    MINOR: Update docs for KIP-229 (#4499)
    
    This PR includes:
    * Minor fix to command line output message
    * Relevant documentation update
---
 core/src/main/scala/kafka/admin/ConsumerGroupCommand.scala |  4 ++--
 docs/ops.html                                              | 12 +++++++++---
 2 files changed, 11 insertions(+), 5 deletions(-)

diff --git a/core/src/main/scala/kafka/admin/ConsumerGroupCommand.scala b/core/src/main/scala/kafka/admin/ConsumerGroupCommand.scala
index 77c5b4d..4c2d6c7 100755
--- a/core/src/main/scala/kafka/admin/ConsumerGroupCommand.scala
+++ b/core/src/main/scala/kafka/admin/ConsumerGroupCommand.scala
@@ -850,7 +850,7 @@ object ConsumerGroupCommand extends Logging {
       }.keySet
 
       if (successfullyDeleted.size == result.size)
-        println(s"Deletion of requested consumer groups (${successfullyDeleted.mkString("'", ", ", "'")}) was successful.")
+        println(s"Deletion of requested consumer groups (${successfullyDeleted.mkString("'", "', '", "'")}) was successful.")
       else {
         printError("Deletion of some consumer groups failed:")
         result.foreach {
@@ -858,7 +858,7 @@ object ConsumerGroupCommand extends Logging {
           case _ => // no need to print successful deletions individually
         }
         if (successfullyDeleted.nonEmpty)
-          println(s"\nThese consumer groups were deleted successfully: ${successfullyDeleted.mkString("'", ", ", "'")}")
+          println(s"\nThese consumer groups were deleted successfully: ${successfullyDeleted.mkString("'", "', '", "'")}")
       }
 
       result
diff --git a/docs/ops.html b/docs/ops.html
index 2c7d06c..49c1674 100644
--- a/docs/ops.html
+++ b/docs/ops.html
@@ -162,9 +162,7 @@
 
   <h4><a id="basic_ops_consumer_group" href="#basic_ops_consumer_group">Managing Consumer Groups</a></h4>
 
-  With the ConsumerGroupCommand tool, we can list, describe, or delete consumer groups. Note that deletion is only available when the group metadata is stored in
-  ZooKeeper. When using the <a href="http://kafka.apache.org/documentation.html#newconsumerapi">new consumer API</a> (where
-  the broker handles coordination of partition handling and rebalance), the group is deleted when the last committed offset for that group expires.
+  With the ConsumerGroupCommand tool, we can list, describe, or delete consumer groups. When using the <a href="http://kafka.apache.org/documentation.html#newconsumerapi">new consumer API</a> (where the broker handles coordination of partition handling and rebalance), the group can be deleted manually, or automatically when the last committed offset for that group expires. Manual deletion works only if the group does not have any active members.
 
   For example, to list all consumer groups across all topics:
 
@@ -223,6 +221,14 @@
     </li>
   </ul>
 
+  To manually delete one or multiple consumer groups, the "--delete" option can be used:
+  <pre class="brush: bash;">
+  &gt; bin/kafka-consumer-groups.sh --bootstrap-server localhost:9092 --delete --group my-group --group my-other-group
+
+  Note: This will not show information about old Zookeeper-based consumers.
+  Deletion of requested consumer groups ('my-group', 'my-other-group') was successful.
+  </pre>
+
   If you are using the old high-level consumer and storing the group metadata in ZooKeeper (i.e. <code>offsets.storage=zookeeper</code>), pass
   <code>--zookeeper</code> instead of <code>bootstrap-server</code>:
 

-- 
To stop receiving notification emails like this one, please contact
jgus@apache.org.