1 files changed, 0 insertions, 3 deletions

diff --git a/a1-policy-management/src/main/java/org/onap/ccsdk/oran/a1policymanagementservice/dmaap/DmaapMessageConsumer.java b/a1-policy-management/src/main/java/org/onap/ccsdk/oran/a1policymanagementservice/dmaap/DmaapMessageConsumer.java
index 1224d00b..47c73506 100644
--- a/a1-policy-management/src/main/java/org/onap/ccsdk/oran/a1policymanagementservice/dmaap/DmaapMessageConsumer.java
+++ b/a1-policy-management/src/main/java/org/onap/ccsdk/oran/a1policymanagementservice/dmaap/DmaapMessageConsumer.java
@@ -95,14 +95,12 @@ public class DmaapMessageConsumer {
         }
 
         void onRequest(long no) {
-            logger.debug("InfiniteFlux.onRequest {}", no);
             for (long i = 0; i < no; ++i) {
                 sink.next(counter++);
             }
         }
 
         void next(FluxSink<Integer> sink) {
-            logger.debug("InfiniteFlux.next");
             this.sink = sink;
             sink.next(counter++);
         }
@@ -213,7 +211,6 @@ public class DmaapMessageConsumer {
 
     private Mono<String> fetchFromDmaap() {
         if (!this.isDmaapConfigured()) {
-            logger.debug("fetchFromDmaap, no action DMAAP not configured");
             return delay().flatMap(o -> Mono.empty());
         }
         logger.debug("fetchFromDmaap");