Rename tbEdgeEventNotificationsTopic

2 years ago · b54e0cd59c
1 changed files with 1 additions and 1 deletions
--- a/common/queue/src/main/java/org/thingsboard/server/queue/discovery/TopicService.java
+++ b/common/queue/src/main/java/org/thingsboard/server/queue/discovery/TopicService.java
@ -44,7 +44,7 @@ public class TopicService {
    @Value("${queue.edge.notifications-topic:tb_edge.notifications}")
    private String tbEdgeNotificationsTopic;

-    @Value("${queue.edge.event-notifications-topic:tb_edge.notifications}")
+    @Value("${queue.edge.event-notifications-topic:tb_edge_event.notifications}")
    private String tbEdgeEventNotificationsTopic;

    private final ConcurrentMap<String, TopicPartitionInfo> tbCoreNotificationTopics = new ConcurrentHashMap<>();