KafkaEdqsStateService - added versionsStore.shutdown()

1 year ago · 36a2b3f666
1 changed files with 1 additions and 0 deletions
--- a/common/edqs/src/main/java/org/thingsboard/server/edqs/state/KafkaEdqsStateService.java
+++ b/common/edqs/src/main/java/org/thingsboard/server/edqs/state/KafkaEdqsStateService.java
@ -224,6 +224,7 @@ public class KafkaEdqsStateService implements EdqsStateService {
        stateConsumer.awaitStop();
        eventsToBackupConsumer.stop();
        stateProducer.stop();
+        versionsStore.shutdown();
    }

 }