如果你在0.9版本以上，可以用最新的Consumer client 客户端，有consumer.seekToEnd() / consumer.position() 可以用于得到当前最新的offset：${log.dirs}/replication-offset-checkpoint
