Consumer Group

server/2024/11/24 5:04:16/

不,kafka-consumer-groups.sh 脚本本身并不用于创建 Consumer Group。它主要用于管理和查看 Consumer Group 的状态和详情,比如列出所有的 Consumer Group、查看特定 Consumer Group 的详情、删除 Consumer Group 等。

Consumer Group 是由 Kafka 消费者客户端在订阅主题时隐式创建的。当你的消费者客户端启动并订阅了特定的主题时,如果指定的 group.id 不存在,Kafka 会自动创建一个新的 Consumer Group。这个过程不需要使用 kafka-consumer-groups.sh 脚本。

kafka-consumer-groups.sh 脚本主要用于以下操作:

  1. 列出所有的 Consumer Group

    kafka-consumer-groups.sh --bootstrap-server <broker_list> --list
    
  2. 查看特定 Consumer Group 的详情

    kafka-consumer-groups.sh --bootstrap-server <broker_list> --describe --group <group_id>
    
  3. 删除 Consumer Group

    kafka-consumer-groups.sh --bootstrap-server <broker_list> --delete --group <group_id>
    

创建 Consumer Group 的过程是通过编写消费者客户端代码并指定 group.id 来完成的,而不是通过 kafka-consumer-groups.sh 脚本。这个脚本是用于管理和监控 Consumer Group 的状态,而不是创建它们。

vi /var/lib/kafka/data/kafka-log0/kafka.properties
/opt/kafka/bin/kafka-console-producer.sh --bootstrap-server 10.10.180.214:4006 --topic tp-00 --producer.config kafka.properties

在这里插入图片描述

/opt/kafka/bin/kafka-console-consumer.sh --bootstrap-server 10.10.180.214:4006 --topic tp-00 --from-beginning --consumer.config kafka.properties

在这里插入图片描述

/opt/kafka/bin/kafka-consumer-groups.sh --bootstrap-server 10.10.180.214:4006 --command-config kafka.properties --list
/opt/kafka/bin/kafka-consumer-groups.sh --bootstrap-server 10.10.180.214:4006 --command-config kafka.properties --describe --group console-consumer-27114

在这里插入图片描述


http://www.ppmy.cn/server/144446.html

相关文章

Nexus搭建go私有仓库,加速下载go依赖包

一、搭建go私库 本文我们梳理一下go依赖包的私库搭建以及使用。 它只分为proxy和group两种仓库&#xff0c;这一点和maven仓库有所不同。 1、创建Blob Stores 为了区分不同的私库依赖包&#xff0c;存储的位置分隔开。 2、新建go proxy官网 Remote storage&#xff1a;htt…

集群聊天服务器(13)redis环境安装和发布订阅命令

目录 环境安装订阅redis发布-订阅的客户端编程环境配置客户端编程 功能测试 环境安装 sudo apt-get install redis-server 先启动redis服务 /etc/init.d/redis-server start默认在6379端口上 redis是存键值对的&#xff0c;还可以存链表、数组等等复杂数据结构 而且数据是在…

数造科技亮相第26届高交会并接受媒体采访,以数据智能赋能未来

11 月 14 日至 16 日&#xff0c;第二十六届中国国际高新技术成果交易会&#xff08;简称“高交会”&#xff09;在深圳成功举办。本届大会以“科技引领发展&#xff0c;产业融合聚变”为主题&#xff0c;汇聚了全球最新的科技成果&#xff0c;打造了一场科技界的盛大聚会。 在…

神经网络问题之二:梯度爆炸(Gradient Explosion)

梯度爆炸&#xff08;Gradient Explosion&#xff09;是神经网络训练过程中常见的一个问题&#xff0c;它指的是在反向传播过程中&#xff0c;梯度值变得非常大&#xff0c;超出了网络的处理范围&#xff0c;从而导致权重更新变得不稳定甚至不收敛的现象。 一、产生原因 梯度爆…

uniapp的renderjs使用

‌uniapp中的RenderJS主要服务于APP和H5平台&#xff0c;其作用包括降低逻辑层和视图层的通讯损耗&#xff0c;提供高性能视图交互能力&#xff0c;以及在视图层操作DOM和运行Web的JS库‌。 RenderJS是uni-app中一个特性&#xff0c;它允许开发者在页面中使用JavaScript直接渲…

Jetpack Compose 生命周期介绍

文章目录 前言1、Compose UI 的生命周期是什么&#xff1f;Compose 生命周期与传统生命周期的对比 2、各阶段详细解析2.1 初次 Composition&#xff1a;UI 的出生2.2 Recomposition&#xff08;UI 更新&#xff09;2.3 Disposal&#xff08;资源清理&#xff09;2.4 生命周期管…

事务的详解

什么是事务&#xff1f; 事务是逻辑上的一组操作&#xff0c;要么都执行&#xff0c;要么都不执行。 另外&#xff0c;需要格外注意的是&#xff1a;事务能否生效数据库引擎是否支持事务是关键。比如常用的 MySQL 数据库默认使用支持事务的 innodb引擎。但是&#xff0c;如果把…

LLaMA-Factory 上手即用教程

LLaMA-Factory 是一个高效的大型语言模型微调工具&#xff0c;支持多种模型和训练方法&#xff0c;包括预训练、监督微调、强化学习等&#xff0c;同时提供量化技术和实验监控&#xff0c;旨在提高训练速度和模型性能。 官方开源地址&#xff1a;https://github.com/hiyouga/L…