求教 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 的整个处理。