求教 jdbctemplate 的 rowmapper 处理如何提前结束

 jdbcTemplate.query(query, new RowMapper<Object>() { @Override public Object mapRow(ResultSet rs, int rowNum) throws SQLException { String data = Utils.ResultSettoString(rs); kafkaTemplate.send(kafkaTopic, tableName, data); return true; } }); 

代码如上，对于查询到的每条数据转换以后发出去，但是有时候有些表比较大，执行时间长，可能需要中断什么的，这时候该怎么中断 rowmapper 的整个处理。