kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From j...@apache.org
Subject [kafka] branch trunk updated: MINOR: Update docs for KIP-229 (#4499)
Date Fri, 02 Feb 2018 06:04:19 GMT
This is an automated email from the ASF dual-hosted git repository.

jgus 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 8b60c8b  MINOR: Update docs for KIP-229 (#4499)
8b60c8b is described below

commit 8b60c8b1417c4a20c17026a7f326c4a502a8797f
Author: Vahid Hashemian <vahidhashemian@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.

Mime
View raw message