Dragon

* 前提是配置consistency参数为true * es监听中afterBulk(long arg0, BulkRequest arg1, Throwable arg2)方法： ```java public void afterBulk(long arg0, BulkRequest arg1, Throwable arg2) { logger.error("bulk got exception:", arg2); for(ActionRequest request : arg1.requests()){ addFailedMsg(request); } }...