文档章节

auto.offset.reset解释

Zero零_度
 Zero零_度
发布于 2016/12/26 09:05
字数 217
阅读 58
收藏 0
[plain] view plain copy
auto.offset.reset   largest   
  
What to do when there is no initial offset in ZooKeeper or if an offset is out of range:  
* smallest : automatically reset the offset to the smallest offset  
* largest : automatically reset the offset to the largest offset  
* anything else: throw exception to the consumer  

当不同group中,如果consumer第一次启动时候,在zookeeper中没有初始的offset(读取的offset,不是logfile 的offset),或者offset过大,那么设置

[plain] view plain copy
smallest和largest才有效,如果smallest重新0开始读取,如果是largest从logfile的offset读取。一般情况下我们都是设置smallest  

当不同group中,如果consumer第一次启动时候,在zookeeper中没有初始的offset(读取的offset,不是logfile 的offset),或者offset过大,那么设置

smallest和largest才有效,如果smallest重新0开始读取,如果是largest从logfile的offset读取。一般情况下我们都是设置smallest  

 

本文转载自:http://blog.csdn.net/linux_ja/article/details/43201501

Zero零_度
粉丝 69
博文 1258
码字总数 257684
作品 0
程序员
私信 提问
Kafka auto.offset.reset值详解

昨天在写一个java消费kafka数据的实例,明明设置auto.offset.reset为earliest,但还是不从头开始消费,官网给出的含义太抽象了。 earliest: automatically reset the offset to the earliest...

舒运
2018/07/18
0
0
Kafka0.10.0.1消费者未启动的情况,生产者启动一段时间,消费者再再启动不会去消费启动之前生产的消息

如题,修改过消费端的参数 auto.offset.reset=earliest 没有效果,然后又去修改了消费者的group.id,这时候可以正常消费之前未被消费的消息了。具体原因未明,请大神解答!...

_Lion
2017/07/13
1K
0
kafka(版本 0.10)已消费过的数据重复消费,而且是3天前的,zk的log未发现异常

kafka(版本 0.10)已消费过的数据重复消费,而且是3天前的,zk的log未发现异常 三台机器分布式消费,下面是消费端配置 props.put("auto.commit.enable", "true"); props.put("auto.commit.in......

-秋风五丈原-
2017/02/13
1K
3
kafka消费reset offset问题

kafka消费端包如下错误: 2016-07-12 14:02:45,076 [ConsumerFetcherThread-order-consumer-group_iZ25mmzglleZ-1468299172455-8b8f5ebd-0-3] ERROR [ConsumerFetcherThread:97] - [Consume......

slimina
2016/07/12
3.3K
2
kafka consumer无法获取topic消息。

Properties properties = new Properties(); properties.put("zookeeper.connect", “192.········”);//声明zk properties.put("group.id", "group2xx");// 必须要使用别的组名称,......

魅影灬紫苑
2017/03/24
545
1

没有更多内容

加载失败,请刷新页面

加载更多

聊聊Elasticsearch的MonitorService

序 本文主要研究一下Elasticsearch的MonitorService MonitorService elasticsearch-7.0.1/server/src/main/java/org/elasticsearch/monitor/MonitorService.java public class MonitorServic......

go4it
42分钟前
3
0
二、Docker

1、Docker - The TLDR(Too Long,Don't Read,Linxu 终端工具 ) Docker是在Linux和Windows上运行的软件。它创建、管理和编排容器。该软件以开源方式开发,在Github上作为Moby开源项目的一部分。...

倪伟伟
55分钟前
3
0
Python猫荐书系列之七:Python入门书籍有哪些?

本文原创并首发于公众号【Python猫】,未经授权,请勿转载。 原文地址:https://mp.weixin.qq.com/s/ArN-6mLPzPT8Zoq0Na_tsg 最近,猫哥的 Python 技术学习群里进来了几位比较特殊的同学:一...

豌豆花下猫
今天
5
0
Guava RateLimiter限流源码解析和实例应用

在开发高并发系统时有三把利器用来保护系统:缓存、降级和限流 缓存 缓存的目的是提升系统访问速度和增大系统处理容量 降级 降级是当服务出现问题或者影响到核心流程时,需要暂时屏蔽掉,待高...

算法之名
今天
13
0
国产达梦数据库与MySQL的区别

背景 由于项目上的需要,把项目实现国产化,把底层的MySQL数据库替换为国产的达梦数据库,花了一周的时间研究了国产的数据库-达梦数据库,它和MySQL有一定的区别,SQL的写法也有一些区别。 ...

TSMYK
今天
3
0

没有更多内容

加载失败,请刷新页面

加载更多

返回顶部
顶部