From d3c636cc2a28f9787810fe2936f24dc461f3b8de Mon Sep 17 00:00:00 2001
From: Akash Goyal <akash.goyal@razorpay.com>
Date: Mon, 7 Nov 2022 14:24:18 +0530
Subject: [PATCH] added check for primary topic

---
 internal/tasks/publishertask.go | 4 +++-
 1 file changed, 3 insertions(+), 1 deletion(-)

diff --git a/internal/tasks/publishertask.go b/internal/tasks/publishertask.go
index cd4c961e..cb8d60c7 100644
--- a/internal/tasks/publishertask.go
+++ b/internal/tasks/publishertask.go
@@ -147,7 +147,9 @@ func (pu *PublisherTask) refreshCache(ctx context.Context) error {
 
 	topicData := make(map[string]bool)
 	for _, topic := range topics {
-		topicData[topic.Name] = true
+		if topic.IsPrimaryTopic() {
+			topicData[topic.Name] = true
+		}
 	}
 
 	TopicCacheData = topicData