X-Git-Url: https://gerrit.onap.org/r/gitweb?a=blobdiff_plain;f=src%2Fmain%2Fjava%2Forg%2Fonap%2Fdmaap%2Fdmf%2Fmr%2Fbackends%2Fkafka%2FKafkaConsumerCache.java;h=647f4ce7b4dce8453433e2be7e3b7c35faa75b62;hb=ab3015141a2cb42308f1d09dc3a7edc8c10cf5c7;hp=04d1d9e51bca0d408df9ee9f439b8b8fdb23e2ee;hpb=0fa52b6adaf4d163a12ca38a750780f99d78b852;p=dmaap%2Fmessagerouter%2Fmsgrtr.git

diff --git a/src/main/java/org/onap/dmaap/dmf/mr/backends/kafka/KafkaConsumerCache.java b/src/main/java/org/onap/dmaap/dmf/mr/backends/kafka/KafkaConsumerCache.java
index 04d1d9e..647f4ce 100644
--- a/src/main/java/org/onap/dmaap/dmf/mr/backends/kafka/KafkaConsumerCache.java
+++ b/src/main/java/org/onap/dmaap/dmf/mr/backends/kafka/KafkaConsumerCache.java
@@ -669,7 +669,7 @@ public class KafkaConsumerCache {
 			Thread.sleep(consumerHandoverWaitMs);
 		} catch (InterruptedException e) {
 			log.error("InterruptedException in signalOwnership",e);
-			Thread.currentThread().interrupt();
+			//Thread.currentThread().interrupt();
 		}
 	}