手动修改zk类型的kafka offset

server/2024/9/22 21:19:00/

手动修改zk类型的 offset:
连接到ZooKeeper

./zkCli.sh -server ..123:2181,.…87.124:2181,1*.*.87.125:2181
查找并修改ae_spark这个topic的消费者组的offset值
对于每个分区（0、1、2），需要分别查看和修改offset值

查看和修改分区0的offset值
查看当前offset值：
get /consumers/ae_spark/offsets/ae_spark/0
这个命令会返回当前的offset值。

设置新的offset值（假设新的offset值为1000，你可以根据需要修改这个值）：
set /consumers/ae_spark/offsets/ae_spark/0 1000

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

【中仕公考怎么样】公务员行测考什么内容?

行政职业能力测验，也就是我们常说的“行测”。是公务员考试笔试环节中的核心科目，占据总成绩的50%。主要考察考生在言语理解与表达、数量关系、判断推理、资料分析和常识判断方面的能力。国考行测分为副省级、地市级以及行政执法类，题目数量…

php7.1编译安装

1.安装必要的工具： 首先确保您已经安装了 Xcode 和 Command Line Tools：xcode-select --install2.下载 PHP 7.1 源代码： 访问 PHP 官方网站下载 PHP 7.1 的源代码： wget https://www.php.net/distributions/php-7.1.33.tar.gz t…

vue3中的组件通信

props通信可以实现父子组件通信，props数据还是只读的！！！ <template><div class"box"><h1>props:我是父组件曹操</h1><hr /><Child info"我是曹操" :money"money&qu…

jenkins 发布镜像清理

概述我们在使用jenkins执行build命令时，偶尔会产生一些版本为none的镜像，但是这些镜像是完全没有用的，占用了磁盘空间，需要定期清理。脚本清理编辑脚本clean_docker_image.sh #!/bin/bash # docker删除none镜像 docker rmi $(d…

Leetcode JAVA刷刷站（69）x的平方根

一、题目概述二、思路方向在Java中，计算一个非负整数x的算术平方根，并返回其整数部分，你可以使用二分查找法。这是因为平方根函数是单调递增的，所以我们可以利用二分查找在合理的时间复杂度内找到结果。三、代码实现 public…

【设计模式】构造器模式和原型模式

构造器模式如果我们系统中有多个员工，创建每一个员工都需要 new 一下，出现很多重复代码，所以我们可以将他们写成一个构造函数，然后通过传入的不同参数创建不同的员工。 function Employee(name, age) {this.name namethis.age…

leetcode 26 删除有序数组中的重复项

正文本题使用双指针解法即可，右指针移动，若右指针所指向元素与左指针指向元素一致，右侧指针继续右移，若右指针指向元素与做左指针指向元素不一致，左指针位置 1，且令左指针处元素等于右指针处元素。 class…

使用docker compose一键部署 Portainer

使用docker compose一键部署 Portainer Portainer 是一款轻量级的应用，它提供了图形化界面，用于方便地管理Docker环境，包括单机环境和集群环境。 1、创建安装目录 mkdir /data/partainer/ -p && cd /data/partainer2、创建docker…

手动修改zk类型的kafka offset

相关文章