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=56b37263c0bf267561baefb7f9fe586a22b7c533;hb=076def9c700fdd6472c62c837b0ce067bab55a4c;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..56b3726 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 @@ -22,7 +22,6 @@ package org.onap.dmaap.dmf.mr.backends.kafka; import java.io.IOException; -import java.net.InetAddress; import java.util.ArrayList; import java.util.Collection; import java.util.Enumeration; @@ -34,8 +33,6 @@ import java.util.concurrent.Executors; import java.util.concurrent.ScheduledExecutorService; import java.util.concurrent.TimeUnit; -import javax.annotation.Resource; - import org.I0Itec.zkclient.exception.ZkException; import org.I0Itec.zkclient.exception.ZkInterruptedException; import org.apache.curator.framework.CuratorFramework; @@ -52,8 +49,6 @@ import org.apache.http.annotation.NotThreadSafe; import org.apache.zookeeper.KeeperException; import org.apache.zookeeper.KeeperException.NoNodeException; import org.springframework.beans.factory.annotation.Autowired; -import org.springframework.beans.factory.annotation.Qualifier; -import org.springframework.context.annotation.ComponentScan; import com.att.ajsc.filemonitor.AJSCPropertiesMap; import org.onap.dmaap.dmf.mr.backends.Consumer; @@ -669,7 +664,7 @@ public class KafkaConsumerCache { Thread.sleep(consumerHandoverWaitMs); } catch (InterruptedException e) { log.error("InterruptedException in signalOwnership",e); - Thread.currentThread().interrupt(); + //Thread.currentThread().interrupt(); } }