summaryrefslogtreecommitdiffstats
path: root/src/main/java/com/att/dmf/mr/beans
diff options
context:
space:
mode:
authorRam Koya <rk541m@att.com>2018-09-07 15:32:53 +0000
committerGerrit Code Review <gerrit@onap.org>2018-09-07 15:32:53 +0000
commit12635b7ef13b0a1b4954ace5f6df5ee3a742f555 (patch)
tree113e8ffd007e9cacae527145dd79d0debed2c339 /src/main/java/com/att/dmf/mr/beans
parent9b7af8ef16ca5362d5d43ffe2451f49de87e749a (diff)
parente696f4e0828d2f26921e233aeede05c4359770a7 (diff)
Merge "Fix NPE issue in msgrt"
Diffstat (limited to 'src/main/java/com/att/dmf/mr/beans')
-rw-r--r--src/main/java/com/att/dmf/mr/beans/DMaaPKafkaConsumerFactory.java8
1 files changed, 5 insertions, 3 deletions
diff --git a/src/main/java/com/att/dmf/mr/beans/DMaaPKafkaConsumerFactory.java b/src/main/java/com/att/dmf/mr/beans/DMaaPKafkaConsumerFactory.java
index e4e09c8..f60fd53 100644
--- a/src/main/java/com/att/dmf/mr/beans/DMaaPKafkaConsumerFactory.java
+++ b/src/main/java/com/att/dmf/mr/beans/DMaaPKafkaConsumerFactory.java
@@ -185,9 +185,11 @@ public class DMaaPKafkaConsumerFactory implements ConsumerFactory {
log.info("Creating Kafka consumer for group [" + consumerGroupName + "], consumer [" + consumerId
+ "], on topic [" + topic + "].");
-
- fCache.signalOwnership(topic, consumerGroupName, consumerId);
-
+
+ if (fCache != null) {
+ fCache.signalOwnership(topic, consumerGroupName, consumerId);
+ }
+
final Properties props = createConsumerConfig(topic,consumerGroupName, consumerId);
long fCreateTimeMs = System.currentTimeMillis();
KafkaConsumer<String, String> cc = new KafkaConsumer<>(props);