X-Git-Url: https://gerrit.onap.org/r/gitweb?a=blobdiff_plain;f=appc-adapters%2Fappc-dmaap-adapter%2Fappc-dmaap-adapter-bundle%2Fsrc%2Fmain%2Fjava%2Forg%2Fonap%2Fappc%2Fadapter%2Fmessaging%2Fdmaap%2Fimpl%2FDmaapProducerImpl.java;fp=appc-adapters%2Fappc-dmaap-adapter%2Fappc-dmaap-adapter-bundle%2Fsrc%2Fmain%2Fjava%2Forg%2Fonap%2Fappc%2Fadapter%2Fmessaging%2Fdmaap%2Fimpl%2FDmaapProducerImpl.java;h=5f91ca33b50e47716b5d741140bce2a2f04aa50f;hb=7ad6c46b3fa55967fa58b39622271c867c0ac203;hp=888b432b0bb461d5cbc9fb71c2a5989f7e83de97;hpb=eec180e689f0243accf0439588c08a29186a2bc2;p=appc.git

diff --git a/appc-adapters/appc-dmaap-adapter/appc-dmaap-adapter-bundle/src/main/java/org/onap/appc/adapter/messaging/dmaap/impl/DmaapProducerImpl.java b/appc-adapters/appc-dmaap-adapter/appc-dmaap-adapter-bundle/src/main/java/org/onap/appc/adapter/messaging/dmaap/impl/DmaapProducerImpl.java
index 888b432b0..5f91ca33b 100644
--- a/appc-adapters/appc-dmaap-adapter/appc-dmaap-adapter-bundle/src/main/java/org/onap/appc/adapter/messaging/dmaap/impl/DmaapProducerImpl.java
+++ b/appc-adapters/appc-dmaap-adapter/appc-dmaap-adapter-bundle/src/main/java/org/onap/appc/adapter/messaging/dmaap/impl/DmaapProducerImpl.java
@@ -123,7 +123,7 @@ public class DmaapProducerImpl implements Producer {
                 final MRBatchingPublisher client = MRClientFactory.createBatchingPublisher (topicProducerPropFileName);
                 out.add(client);
             } catch (Exception e) {
-                e.printStackTrace();
+                LOG.error(e.getMessage());
             }
         }
 
@@ -161,7 +161,7 @@ public class DmaapProducerImpl implements Producer {
                 LOG.debug(String.format("Posting %s to %s", data, client));
                 client.send(partition, data);
             } catch (IOException e) {
-                e.printStackTrace();
+                LOG.error(e.getMessage());
                 success = false;
             }
         }
@@ -186,7 +186,6 @@ public class DmaapProducerImpl implements Producer {
                 client.close(1, TimeUnit.SECONDS);
             }  catch (IOException | InterruptedException e) {
                 LOG.warn(String.format("Failed to cleanly close Dmaap connection for [%s]", client));
-                e.printStackTrace();
             }
         }
     }