Github user hmcl commented on a diff in the pull request: https://github.com/apache/storm/pull/2467#discussion_r159120311 --- Diff: external/storm-solr/src/main/java/org/apache/storm/solr/bolt/SolrUpdateBolt.java --- @@ -88,9 +92,11 @@ private int capacity() { @Override protected void process(Tuple tuple) { try { + LOG.debug("Processing Tuple: {}", tuple); SolrRequest request = solrMapper.toSolrRequest(tuple); solrClient.request(request, solrMapper.getCollection()); ack(tuple); + LOG.debug("Acked Tuple: {}", tuple); --- End diff -- Same as above
---