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
---