From 826b82ce861bebf17521a410caf4dd06343c2856 Mon Sep 17 00:00:00 2001
From: PatrikBuhr <patrik.buhr@est.tech>
Date: Wed, 19 Jan 2022 10:19:23 +0100
Subject: [PATCH] Bugfix

All kafka listeners was restared every minute. But only broken ones should be restarted.
This would lead to lost data.

Signed-off-by: PatrikBuhr <patrik.buhr@est.tech>
Issue-ID: NONRTRIC-703
Change-Id: I876f946b0de73f39ada5a975a5e325a3952ae744
---
 .../main/java/org/oran/dmaapadapter/tasks/KafkaTopicConsumers.java    | 4 +++-
 1 file changed, 3 insertions(+), 1 deletion(-)

diff --git a/dmaap-adaptor-java/src/main/java/org/oran/dmaapadapter/tasks/KafkaTopicConsumers.java b/dmaap-adaptor-java/src/main/java/org/oran/dmaapadapter/tasks/KafkaTopicConsumers.java
index 48090170..5233401b 100644
--- a/dmaap-adaptor-java/src/main/java/org/oran/dmaapadapter/tasks/KafkaTopicConsumers.java
+++ b/dmaap-adaptor-java/src/main/java/org/oran/dmaapadapter/tasks/KafkaTopicConsumers.java
@@ -100,7 +100,9 @@ public class KafkaTopicConsumers {
     public synchronized void restartNonRunningTopics() {
         for (String typeId : this.consumers.keySet()) {
             for (KafkaJobDataConsumer consumer : this.consumers.get(typeId)) {
-                restartTopic(consumer);
+                if (!consumer.isRunning()) {
+                    restartTopic(consumer);
+                }
             }
         }
     }
-- 
2.16.6