分布式消息服务KAFKA版-删除Kafka消费组:方法二:使用命令行工具删除消费组

时间:2024-07-03 09:09:40

方法二:使用命令行工具删除消费组

以下操作命令以Linux系统为例进行说明:

  1. 下载Kafka命令行工具1.1.0版本或者Kafka命令行工具2.3.0版本或者Kafka命令行工具2.7.2版本或者Kafka命令行工具3.4.0版本,确保Kafka实例版本与命令行工具版本相同。
  2. 使用命令行工具连接Kafka实例,具体步骤请参考使用客户端连接Kafka(明文接入)使用客户端连接Kafka(密文接入)
  3. 在Kafka客户端的“/bin”目录下,执行以下命令删除消费组。

    ./kafka-consumer-groups.sh --bootstrap-server ${connection-address} --delete --group ${consumer-group-name}

    示例如下:

    [root@zk-server-1 bin]# ./kafka-consumer-groups.sh --bootstrap-server 192.168.1.245:9091,192.168.1.86:9091,192.168.1.128:9091 --delete --group bbbb
    Note: This will not show information about old Zookeeper-based consumers.
    Deletion of requested consumer groups ('bbbb') was successful.

    如果Kafka实例开启密文接入,则以上命令还需要增加SASL认证的“consumer.properties”配置文件参数: --command-config {SASL认证的consumer.properties配置文件},“consumer.properties”配置文件参考使用客户端连接Kafka(密文接入)

support.huaweicloud.com/usermanual-kafka/kafka-ug-0012.html