kafka使用getOffsetsBefore()获取获取offset异常分析

根据时间戳获取kafka的topic的偏移量，结果获取的偏移量量数据组的长度为0，就会出现如下的数组下标越界的异常，实现的原理是使用了kafka的getOffsetsBefore（）方法: Exception in thread "main" java.lang.ArrayIndexOutOfBou
posted @ 2016-03-07 11:09  丹江湖畔养蜂子赵大爹  阅读(4409)  评论(0)  编辑  收藏  举报