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;fp=src%2Fmain%2Fjava%2Forg%2Fonap%2Fdmaap%2Fdmf%2Fmr%2Fbackends%2Fkafka%2FKafkaConsumerCache.java;h=647f4ce7b4dce8453433e2be7e3b7c35faa75b62;hb=ab3015141a2cb42308f1d09dc3a7edc8c10cf5c7;hp=00b6a75767f77dd9a9a83f01ac31d5189374ff48;hpb=7823ae72abf905f77842d533374b7f2ebb7c0b34;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 00b6a75..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
@@ -299,7 +299,7 @@ public class KafkaConsumerCache {
 				curator.blockUntilConnected();
 			} catch (InterruptedException e) {
 				log.error("error while setting curator framework :",e);
-				//Thread.currentThread().interrupt();
+				Thread.currentThread().interrupt();
 			}
 		}
 
@@ -512,7 +512,7 @@ public class KafkaConsumerCache {
 			Thread.sleep(consumerHandoverWaitMs);
 		} catch (InterruptedException e) {
 			log.error("InterruptedException in dropTimedOutConsumer",e);
-			//Thread.currentThread().interrupt();
+			Thread.currentThread().interrupt();
 		}
 		log.info("Dropped " + key + " consumer due to timeout");
 	}