diff options
Diffstat (limited to 'src/main/java/org/onap/dmaap/dmf/mr/backends/kafka/KafkaConsumerCache.java')
-rw-r--r-- | src/main/java/org/onap/dmaap/dmf/mr/backends/kafka/KafkaConsumerCache.java | 6 |
1 files changed, 3 insertions, 3 deletions
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..00b6a75 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"); } @@ -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(); } } |