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