kafka重置offset

摘要：

Kafka重置offset1。删除zookeeper上的节点信息并打开客户端：/ZkCli.sh-server127.0.0.1:12181 Delete consumer:rmr/consumers/xxxx。代码设置为从最小值读取（注意，zk上的使用者在程序启动之前不存在）props.put（“auto.foffset.reset”，“minimal”）；

kafka重置offset

1.删除zookeeper上节点信息

打开client ：./zkCli.sh -server 127.0.0.1:12181

删除consumer：rmr /consumers/xxx

2.代码中设置从最小读（注意程序启动前保证zk上的consumer不存在）

props.put("auto.offset.reset", "smallest");

免责声明：文章转载自《kafka重置offset》仅用于学习参考。如对内容有疑问，请及时联系本站处理。

上篇Linux内核配置、编译及Makefile简述Java命令学习系列(一)：Jps下篇

宿迁高防，2C2G15M，22元/月；香港BGP，2C5G5M，25元/月雨云优惠码：MjYwNzM=

随便看看

百度文库破解方法

通过这些步骤，我们可以轻松破解百度文库下载，简单实用。互联网上有很多种下载设备，它们很容易使用和解决。...

sql 加减时间

另外，MySQL中还有两个函数subdate(),subtime()，建议，用date_sub()来替代。MySQLperiod_add(P,N)：日期加/减去N月。mysql˃selectperiod_add,period_add|period_add|period_add|结果|200810|20080806|MySQLperiod_diff：日期P1-...

ubuntu 常见安装软件错误

安装xlibs dev.2。错误：apt-get-installlibqt3-headers libqt3-mt-dev3。错误：这基本上意味着它要安装许多KDEspecificpackagestowork。这个'configure:aapt-get-installbuild essential7。错误：...

Linux查看机器和硬盘的SN

查看硬件RAID中硬盘的SN#sas端口：[root@~]$smartctl-a/dev/sda dmegaraid，n***序列号：6RJ974SR***#sat端口[root@~]$smarttl-a/dev/sda-dsat+megaraid，n***序列号：6BRJ974SR***查看机器SN[root@~~]$dmidcode-t1**序列号...

Android 上的 10 款 Web 开发工具推荐

作为一个狂热的Android用户，我一直在寻找适合Web开发人员使用的一些应用程序。以下推荐10款非常实用的Android端的Web开发工具。EditorJoooid1.1Editor这款工具非常适合用来发布包含HTML、文本、图片和相册的文章，还包含了GPL定位信息。...

codeforces 765 F Souvenirs 线段树+set

问题的含义：多个查询的间隔中两个数字之差的绝对值的最小值：可以根据查询的l对脱机查询进行排序，并且可以从r到l进行反向查询，并且间隔i+1到n的每次更新都可以确保此更新不会影响下一次和后续更新。因为当两个区间相互覆盖时，具有较小l的区间的值必须小于或等于另一个区间，因此可以绘制一个图来理解。...

最新文章

随机推荐