kafka(版本 0.10)已消费过的数据重复消费,而且是3天前的,zk的log未发现异常
< 返回列表时间: 2017-02-13来源:开源中国
HDC调试需求开发(15万预算),能者速来!>>>
kafka(版本 0.10)已消费过的数据重复消费,而且是3天前的,zk的log未发现异常
三台机器分布式消费,下面是消费端配置
props.put("auto.commit.enable", "true");
props.put("auto.commit.interval.ms", "1000");
props.put("max.poll.records", "1");
props.put("auto.offset.reset", "earliest");
急,请教!!!
热门排行