kafka批量插入问题

kafka 怎么获取最新的offset啊，我要做批量插入功能但是最后一条会被hasnext阻塞掉，很难受.大神指点下，最好不要做监控，因为我的每个线程内部有一个map。现在的逻辑是满2000条进行批量插入，但是如果不满2000的就一直卡死了，一直等到有数据才行。