consumer.commitSync();
这个放到抛异常的后面。